All Classes and Interfaces
Class
Description
Authentication data.
Interface of authentication providers.
Interface for accessing data which are used in variety of authentication schemes on client side.
Factory class that allows to create
Authentication instances
for all the supported authentication methods.Batcher builder.
Batch message container for individual messages being published until they are batched and sent to broker.
Configuration for message batch receive
Consumer.batchReceive() Consumer.batchReceiveAsync().Builder of BatchReceivePolicy.
Builder interface that is used to configure and construct a
PulsarClient instance.The compression type that can be specified on a
Producer.An interface that abstracts behavior of Pulsar's consumer.
ConsumerBuilder is used to configure and create instances of Consumer.The action a consumer should take when a consumer receives a
message that it cannot decrypt.
Listener on the consumer state changes.
A plugin interface that allows you to intercept (and possibly mutate)
messages received by the consumer.
Consumer statistics recorded by client.
Interface that abstracts the access to a key store.
Configuration for the "dead letter queue" feature in consumer.
Helper class for class instantiations and it also contains methods to work with schemas.
Support for encoded authentication configuration parameters.
Class representing an encryption context.
Encryption key with metadata.
EncryptionKeyInfo contains the encryption key and corresponding metadata which contains additional information about
the key such as version, timestamp.
A field in a record, consisting of a field name, index, and
Schema for the field value.Build a field for a record.
An interface represents a message with schema.
Generic Record Builder to build a
GenericRecord.A schema that serializes and deserializes between
GenericRecord and bytes.Standard hashing functions available when choosing the partition to use for a particular message.
KeyShared mode of KeyShared subscription.
KeyShared policy for KeyShared subscription.
Auto split hash range key shared policy.
Sticky attach topic with fixed hash range.
KeyStore parameters used for tls authentication.
A simple KeyValue class.
Decoder to decode key/value bytes.
Encoding types of supported KeyValueSchema for Pulsar messages.
The message abstraction used in Pulsar.
Interface that abstracts the method to encrypt/decrypt message for End to End Encryption.
Opaque unique identifier of a single message
A listener that will be called in order for every message received.
Interface for custom message router that can be passed
to a producer to select the partition that a particular
messsage should be published on.
Default routing mode for messages to partition.
A container that holds the list
Message for a topic.Producer is used to publish messages on a topic.
ProducerBuilder is used to configure and create instances of Producer.The action the producer will take in case of encryption failures.
A plugin interface that allows you to intercept (and possibly mutate) the
messages received by the producer before they are published to the Pulsar
brokers.
Deprecated.
A wrapper for old style producer interceptor.
Producer statistics recorded by client.
Protcol type to determine type of proxy routing when client connects to proxy using
{@link ClientBuilder::proxyServiceUrl}.
Class that provides a client interface to Pulsar.
Base type of exception thrown by Pulsar client.
Already closed exception thrown by Pulsar client.
Authentication exception thrown by Pulsar client.
Authorization exception thrown by Pulsar client.
Broker metadata exception thrown by Pulsar client.
Broker persistence exception thrown by Pulsar client.
Checksum exception thrown by Pulsar client.
Connect exception thrown by Pulsar client.
Consumer assign exception thrown by Pulsar client.
Consumer busy exception thrown by Pulsar client.
Crypto exception thrown by Pulsar client.
Getting authentication data exception thrown by Pulsar client.
Incompatible schema exception thrown by Pulsar client.
Invalid Configuration exception thrown by Pulsar client.
Invalid message exception thrown by Pulsar client.
Invalid Service URL exception thrown by Pulsar client.
Invalid topic name exception thrown by Pulsar client.
Lookup exception thrown by Pulsar client.
Not allowed exception thrown by Pulsar client.
Not connected exception thrown by Pulsar client.
Not Found exception thrown by Pulsar client.
Not supported exception thrown by Pulsar client.
Producer blocked quota exceeded error thrown by Pulsar client.
Producer blocked quota exceeded exception thrown by Pulsar client.
Producer busy exception thrown by Pulsar client.
Full producer queue error thrown by Pulsar client.
Timeout exception thrown by Pulsar client.
Too many requests exception thrown by Pulsar client.
Topic does not exist and cannot be created.
Topic terminated exception thrown by Pulsar client.
Unsupported authentication exception thrown by Pulsar client.
Int range.
A Reader can be used to scan through all the messages currently available in a topic.
ReaderBuilder is used to configure and create instances of Reader.A listener that will be called in order for every message received.
Building the schema for a
GenericRecord.When subscribing to topics using a regular expression, one can specify
to only pick a certain type of topics.
Message schema definition.
Builder to build schema.
Interface for schema definition.
Builder to build schema definition
SchemaDefinition.Information about the schema.
Schema Provider.
Data structure representing a schema information including its version.
Deserialize messages from bytes.
Schema serialization exception.
Types of supported schema for Pulsar messages.
Serialize messages into bytes.
The provider to provide the service url.
When creating a consumer, if the subscription does not exist, a new subscription will be created.
Types of subscription mode supported by Pulsar.
Types of subscription supported by Pulsar.
Metadata of a topic that can be used for message routing.
The class represents a transaction within Pulsar.
The builder to build a transaction for Pulsar.
Transaction coordinator client.
State of the transaction coordinator client.
Exceptions for transaction coordinator client.
Thrown when transaction coordinator with unexpected state.
Thrown when transaction coordinator not found in broker side.
Thrown when transaction switch to a invalid status.
Thrown when transaction meta store handler not exists.
Thrown when send request to transaction meta store but the transaction meta store handler not ready.
Message builder that constructs a message to be published through a producer.