waitWithContext Same as wait() call, but the end condition can also be controlled through the context. It blocks until either a broadcast occurs or th

BeforeConsume This is called just before the message is send to Consumer's ConsumerMessage channel.

BeforeSend This is called before send the message to the brokers. This method is allowed to modify the message.

Crc32cCheckSum handles computing the checksum.

CreateNamespace creates a new empty namespace with no policies attached

DeleteWithContext deletes an existing cluster

FlushBatches all the messages buffered in multiple batches and wait until all messages have been successfully persisted.

GetBundleRange returns a bundle range of a topic

GetConnections get all connections in the pool.

GetEncryptionContext returns the ecryption context of the message. It will be used by the application to parse the undecrypted message.

GetMaxTopicsPerNamespace returns the maxTopicsPerNamespace for a namespace.

GetMessageID returns the message Id by timestamp(ms) of a topic @param topic topicName struct @param timestamp absolute timestamp (in ms)

GetState Get the state of the transaction.

GetStatsWithOptionWithContext returns the stats for the topic All the rates are computed over a 1-minute window and are relative the last completed 1

GetSubPermissions returns subscription permissions on a namespace

GetSubscriptionExpirationTime gets the subscription expiration time on a namespace. Returns -1 if not set

GetTopicAutoCreation returns the topic auto-creation config for a namespace. Returns nil if the topic auto-creation config is not configured at the na

HealthCheckWithTopicVersion runs a health check on the broker

Index returns index from broker entry metadata, or empty if the feature is not enabled in the broker.

InvalidateToken is called when the token is rejected by the resource server.

IsMaxBackoffReached evaluates if the max number of retries is reached

IsNullValue reports whether the message was published as a null-value (tombstone) message, i.e. with MessageMetadata.null_value set. For such messages

NewAuthDisabled return a interface of Provider

NewAuthenticationFromTLSCertSupplier Create new Authentication provider with specified TLS certificate supplier

NewAuthenticationTLS initialize the authentication provider

NewAuthenticationTLS initialize the authentication provider

NewAuthenticationToken returns a token auth provider that will use the specified token to talk with Pulsar brokers

NewAuthenticationTokenFromFile return a interface of a Provider with a string token file path.

NewAuthenticationTokenFromSupplier returns a token auth provider that gets the token data from a user supplied function. The function is invoked each