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.AutoClusterFailoverBuilder is used to configure and create instance of ServiceUrlProvider.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.
ControlledClusterFailoverBuilder is used to configure and create instance of ServiceUrlProvider.Interface that abstracts the access to a key store.
Configuration for the "dead letter queue" feature in consumer.
This class loads the implementation for
PulsarClientImplementationBinding
and allows you to decouple the API from the actual implementation.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.
This is an abstraction over the logical value that is store into a Message.
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.
Annotation to inform users of a package, class or method's intended audience.
Intended for use only within the project(s) specified in the annotation.
Intended for use only within the project itself.
Intended for use by any project or application.
Annotation to inform users of how much to rely on a particular package,
class or method not changing over time.
Evolving, but can break compatibility at minor release (i.e.
Can evolve while retaining compatibility for minor release boundaries.;
can break compatibility only at major release (ie.
No guarantee is provided as to reliability or stability across any
level of release granularity.
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.
This interface models a Schema that is composed of two parts.
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.
The abstraction of a message's payload.
The context of the message payload, which usually represents a batched message (batch) or a single message.
The factory class of
MessagePayload.The processor to process a message payload.
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.Multi-topic Consumer statistics recorded by client.
Partitioned topic Producer statistics recorded by client.
Producer is used to publish messages on a topic.
The type of access to the topic that the producer requires.
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.
Internal utility methods for filtering and mapping
Properties objects.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.
Memory buffer full error thrown by Pulsar client.
Consumer assign 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.
Producer fenced 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.
Consumer assign exception thrown by Pulsar client.
Unsupported authentication exception thrown by Pulsar client.
Helper class for class instantiations and it also contains methods to work with schemas.
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.Reader interceptor.
A listener that will be called in order for every message received.
Building the schema for a
GenericRecord.Interface for custom message is negativeAcked policy, users can specify a
RedeliveryBackoff for
a consumer.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.
Size unit converter.
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.
TableViewBuilder is used to configure and create instances of TableView.TopicConsumerBuilder is used to configure topic specific options to override those set at the
ConsumerBuilder level.Metadata of a topic that can be used for message routing.
The class represents a transaction within Pulsar.
The transaction buffer client to commit and abort transactions on topics or subscription.
Exceptions for transaction buffer client.
Thrown when transaction buffer op over max pending numbers.
Thrown when operation timeout.
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.
Thrown when transaction not found in transaction coordinator.
An identifier for representing a transaction.
Message builder that constructs a message to be published through a producer.