Package log defines the logger interfaces used by pulsar client.

DeserializeMessageID reconstruct a MessageID object from its serialized representation.

EarliestMessageID returns a messageID that points to the earliest message available in a topic.

LatestMessageID returns a messageID that points to the latest message.

NewAuthentication Creates an authentication by name and params.

NewAuthenticationAthenz Creates Athenz Authentication provider.

NewAuthenticationFromTLSCertSupplier Create new Authentication provider with specified TLS certificate supplier.

NewAuthenticationOAuth2 Creates OAuth2 Authentication provider.

NewAuthenticationTLS Creates new Authentication provider with specified TLS certificate and private key.

NewAuthenticationToken Creates new Authentication provider with specified auth token.

NewAuthenticationTokenFromFile Creates new Authentication provider with specified auth token from a file.

NewAuthenticationTokenFromSupplier returns a token auth provider that gets the token data from a user supplied function.

NewClient Creates a pulsar client instance.

NewDefaultRouter set the message routing mode for the partitioned producer.

NewKeySharedPolicySticky construct KeySharedPolicy in Sticky mode with hashRanges formed in value pair list: [x1, x2, y1, y2, z1, z2], and must not overlap with each others.

AddToBatchFailed failed to add sendRequest to batchBuilder.

AlreadyClosedError producer/consumer is already closed and not accepting any operation.

AuthenticationError means authentication failed on broker.

AuthorizationError client is not authorized to create producer/consumer.

.

Auto Consume Type.

Auto Publish Type.

Serialize and deserialize via Avro.

Higher compression rate, but slower.

.

BrokerMetadataError broker failed in updating metadata.

BrokerPersistenceError broker failed to persist entry.

A bytes array.

ChecksumError corrupt message checksum failure.

ConnectError means failed to connect to broker.

ConsumerBusy means Exclusive consumer is already connected.

ConsumerClosed means consumer already been closed.

ConsumerNotFound consumer not found.

ConsumerNotInitialized consumer is not initialized.

CryptoError error when crypto operation fails.

Default compression level.

A double number.

ErrorGettingAuthenticationData client cannot find authorization data.

Exclusive there can be only 1 consumer on the same topic with the same subscription name.

Failover subscription mode, multiple consumer will be able to use the same subscription name but only 1 consumer will receive the messages.

Faster compression, with lower compression ratio.

A float number.

A 16-byte integer.

A 32-byte integer.

A 64-byte integer.

A 8-byte integer.

InvalidBatchBuilderType invalid batch builder type.

InvalidConfiguration means invalid configuration.

InvalidMessage error in publishing an already used message.

InvalidTopicName means invalid topic name.

InvalidURL means Client Initialized with Invalid Broker Url (VIP Url passed to Client Constructor).

JavaStringHash and Java String.hashCode() equivalent.

JSON object encoding and validation.

KeyShared subscription mode, multiple consumer will be able to use the same subscription and all messages with the same key will be dispatched to only one consumer.

KeySharedPolicyModeAutoSplit Auto split hash range key shared policy.

KeySharedPolicyModeSticky is Sticky attach topic with fixed hash range.

A Schema that contains Key Schema and Value Schema.

LookupError means broker lookup failed.

MessageTooBig trying to send a messages exceeding the max size.

Label metrics by tenant and namespace.

Do not add additional labels to metrics.

Label metrics by tenant.

Label metrics by topic.

Murmur3_32Hash use Murmur3 hashing function.

No schema defined.

NotConnectedError producer/consumer is not currently connected to broker.

Ok means no errors.

OperationNotSupported operation not supported.

ProducerBlockedQuotaExceededError producer is blocked.

ProducerBlockedQuotaExceededException producer is getting exception.

ProducerClosed means producer already been closed.

ProducerNotInitialized producer is not initialized.

ProducerQueueIsFull producer queue is full.

Protobuf message encoding and decoding.

ReadError means failed to read from socket.

SeekFailed seek failed.

ServiceUnitNotReady unloaded between client did lookup and producer/consumer got created.

Shared subscription mode, multiple consumer will be able to use the same subscription name and the messages will be dispatched according to a round-robin rotation between the connected consumers.

Simple String encoding with UTF-8.

SubscriptionNotFound subscription not found.

SubscriptionPositionEarliest is the earliest position which means the start consuming position will be the first message.

SubscriptionPositionLatest is the latest position which means the start consuming position will be the last message.

TimeoutError means operation timed out.

TooManyLookupRequestException too many concurrent LookupRequest.

TopicNotFound topic not found.

TopicTerminated topic was already terminated.

UnknownError means unknown error happened on broker.

UnsupportedVersionError when an older client/version doesn't support a required feature.

ClientOptions is used to construct a Pulsar Client instance.

ConsumerMessage represents a pair of a Consumer and Message.

ConsumerOptions is used to configure and create instances of Consumer.

DLQPolicy represents the configuration for the Dead Letter Queue consumer policy.

EncryptionContext It will be used to decrypt message outside of this client.

EncryptionKey Encryption key used to encrypt the message payload.

Error implement error interface, composed of two parts: msg and result.

KeySharedPolicy for KeyShared subscription.

MessageDecryptionInfo encryption related fields required by the consumer to decrypt the message.

ProducerEncryptionInfo encryption related fields required by the producer.

ProducerMessage abstraction used in Pulsar producer.

ReaderMessage packages Reader and Message as a struct to use.

ReaderOptions represents Reader options to use.

Encapsulates data around the schema definition.

TableViewOptions contains the options for creating a TableView.

Authentication Opaque interface that represents the authentication credentials.

Client represents a pulsar client.

Consumer is an interface that abstracts behavior of Pulsar's consumer.

Message abstraction used in Pulsar.

MessageID identifier for a particular message.

NackBackoffPolicy is a interface for custom message negativeAcked policy, users can specify a NackBackoffPolicy for a consumer.

Producer is used to publish messages on a topic.

Reader can be used to scan through all the messages currently available in a topic.

TableView provides a key-value map view of a compacted topic.

TopicMetadata represents a topic metadata.

MetricsCardinality represents the specificty of labels on a per-metric basis.

Result used to represent pulsar processing is an alias of type int.

SubscriptionType of subscription supported by Pulsar.