Package org.apache.pulsar.client.api

package org.apache.pulsar.client.api

Pulsar Client API.

Related Packages

Package	Description
org.apache.pulsar.client.api.interceptor	Pulsar interceptors.
org.apache.pulsar.client.api.schema	Schema definitions for Pulsar Client API.
org.apache.pulsar.client.api.transaction	Pulsar transaction related API.

Class	Description
Authentication	Interface of authentication providers.
AuthenticationDataProvider	Interface for accessing data which are used in variety of authentication schemes on client side.
AuthenticationFactory	Factory class that allows to create Authentication instances for all the supported authentication methods.
AutoClusterFailoverBuilder	AutoClusterFailoverBuilder is used to configure and create instance of ServiceUrlProvider.
AutoClusterFailoverBuilder.FailoverPolicy
BatcherBuilder	Batcher builder.
BatchMessageContainer	Batch message container for individual messages being published until they are batched and sent to broker.
BatchReceivePolicy	Configuration for message batch receive Consumer.batchReceive() Consumer.batchReceiveAsync().
BatchReceivePolicy.Builder	Builder of BatchReceivePolicy.
ClientBuilder	Builder interface that is used to configure and construct a PulsarClient instance.
CompressionType	The compression type that can be specified on a Producer.
Consumer<T>	An interface that abstracts behavior of Pulsar's consumer.
ConsumerBuilder<T>	ConsumerBuilder is used to configure and create instances of Consumer.
ConsumerCryptoFailureAction	The action a consumer should take when a consumer receives a message that it cannot decrypt.
ConsumerEventListener	Listener on the consumer state changes.
ConsumerInterceptor<T>	A plugin interface that allows you to intercept (and possibly mutate) messages received by the consumer.
ConsumerStats	Deprecated. use ClientBuilder.openTelemetry(OpenTelemetry) to enable stats
ControlledClusterFailoverBuilder	ControlledClusterFailoverBuilder is used to configure and create instance of ServiceUrlProvider.
CryptoKeyReader	Interface that abstracts the access to a key store.
DeadLetterPolicy	Configuration for the "dead letter queue" feature in consumer.
DummyCryptoKeyReaderImpl	An empty implement.
EncodedAuthenticationParameterSupport	Support for encoded authentication configuration parameters.
EncryptionKeyInfo	EncryptionKeyInfo contains the encryption key and corresponding metadata which contains additional information about the key such as version, timestamp.
HashingScheme	Standard hashing functions available when choosing the partition to use for a particular message.
KeySharedMode	KeyShared mode of KeyShared subscription.
KeySharedPolicy	KeyShared policy for KeyShared subscription.
KeySharedPolicy.KeySharedPolicyAutoSplit	Auto split hash range key shared policy.
KeySharedPolicy.KeySharedPolicySticky	Sticky attach topic with fixed hash range.
KeyStoreParams	KeyStore parameters used for tls authentication.
Message<T>	The message abstraction used in Pulsar.
MessageAcknowledger	The interface to acknowledge one or more messages individually or cumulatively.
MessageCrypto<MetadataT,BuilderT>	Interface that abstracts the method to encrypt/decrypt message for End to End Encryption.
MessageId	Opaque unique identifier of a single message
MessageListener<T>	A listener that will be called in order for every message received.
MessageListenerExecutor	Interface for providing service to execute message listeners.
MessagePayload	The abstraction of a message's payload.
MessagePayloadContext	The context of the message payload, which usually represents a batched message (batch) or a single message.
MessagePayloadFactory	The factory class of MessagePayload.
MessagePayloadProcessor	The processor to process a message payload.
MessageRouter	Interface for custom message router that can be passed to a producer to select the partition that a particular messsage should be published on.
MessageRoutingMode	Default routing mode for messages to partition.
Messages<T>	A container that holds the list Message for a topic.
MultiTopicConsumerStats	Multi-topic Consumer statistics recorded by client.
PartitionedTopicProducerStats	Partitioned topic Producer statistics recorded by client.
Producer<T>	Producer is used to publish messages on a topic.
ProducerAccessMode	The type of access to the topic that the producer requires.
ProducerBuilder<T>	ProducerBuilder is used to configure and create instances of Producer.
ProducerCryptoFailureAction	The action the producer will take in case of encryption failures.
ProducerInterceptor<T>	Deprecated.
ProducerStats	Deprecated. use ClientBuilder.openTelemetry(OpenTelemetry) to enable stats
ProxyProtocol	Protcol type to determine type of proxy routing when client connects to proxy using invalid @link {@link ClientBuilder::proxyServiceUrl }.
PulsarClient	Class that provides a client interface to Pulsar.
PulsarClientException	Base type of exception thrown by Pulsar client.
PulsarClientException.AlreadyClosedException	Already closed exception thrown by Pulsar client.
PulsarClientException.AuthenticationException	Authentication exception thrown by Pulsar client.
PulsarClientException.AuthorizationException	Authorization exception thrown by Pulsar client.
PulsarClientException.BrokerMetadataException	Broker metadata exception thrown by Pulsar client.
PulsarClientException.BrokerPersistenceException	Broker persistence exception thrown by Pulsar client.
PulsarClientException.ChecksumException	Checksum exception thrown by Pulsar client.
PulsarClientException.ConnectException	Connect exception thrown by Pulsar client.
PulsarClientException.ConsumerAssignException	Consumer assign exception thrown by Pulsar client.
PulsarClientException.ConsumerBusyException	Consumer busy exception thrown by Pulsar client.
PulsarClientException.CryptoException	Crypto exception thrown by Pulsar client.
PulsarClientException.FailedFeatureCheck	"supports_auth_refresh" was introduced at "2.6" and is no longer supported, so skip this enum.
PulsarClientException.FeatureNotSupportedException	Not supported exception thrown by Pulsar client.
PulsarClientException.GettingAuthenticationDataException	Getting authentication data exception thrown by Pulsar client.
PulsarClientException.IncompatibleSchemaException	Incompatible schema exception thrown by Pulsar client.
PulsarClientException.InvalidConfigurationException	Invalid Configuration exception thrown by Pulsar client.
PulsarClientException.InvalidMessageException	Invalid message exception thrown by Pulsar client.
PulsarClientException.InvalidServiceURL	Invalid Service URL exception thrown by Pulsar client.
PulsarClientException.InvalidTopicNameException	Invalid topic name exception thrown by Pulsar client.
PulsarClientException.LookupException	Lookup exception thrown by Pulsar client.
PulsarClientException.MemoryBufferIsFullError	Memory buffer full error thrown by Pulsar client.
PulsarClientException.MessageAcknowledgeException	Consumer assign exception thrown by Pulsar client.
PulsarClientException.NotAllowedException	Not allowed exception thrown by Pulsar client.
PulsarClientException.NotConnectedException	Not connected exception thrown by Pulsar client.
PulsarClientException.NotFoundException	Not Found exception thrown by Pulsar client.
PulsarClientException.NotSupportedException	Not supported exception thrown by Pulsar client.
PulsarClientException.ProducerBlockedQuotaExceededError	Producer blocked quota exceeded error thrown by Pulsar client.
PulsarClientException.ProducerBlockedQuotaExceededException	Producer blocked quota exceeded exception thrown by Pulsar client.
PulsarClientException.ProducerBusyException	Producer busy exception thrown by Pulsar client.
PulsarClientException.ProducerFencedException	Producer fenced exception thrown by Pulsar client.
PulsarClientException.ProducerQueueIsFullError	Full producer queue error thrown by Pulsar client.
PulsarClientException.SubscriptionNotFoundException	Not found subscription that cannot be created.
PulsarClientException.TimeoutException	Timeout exception thrown by Pulsar client.
PulsarClientException.TooManyRequestsException	Too many requests exception thrown by Pulsar client.
PulsarClientException.TopicDoesNotExistException	Topic does not exist and cannot be created.
PulsarClientException.TopicMigrationException	TopicMigration exception thrown by Pulsar client.
PulsarClientException.TopicTerminatedException	Topic terminated exception thrown by Pulsar client.
PulsarClientException.TransactionConflictException	Consumer assign exception thrown by Pulsar client.
PulsarClientException.TransactionHasOperationFailedException
PulsarClientException.UnsupportedAuthenticationException	Unsupported authentication exception thrown by Pulsar client.
Range	Int range.
Reader<T>	A Reader can be used to scan through all the messages currently available in a topic.
ReaderBuilder<T>	ReaderBuilder is used to configure and create instances of Reader.
ReaderInterceptor<T>	Reader interceptor.
ReaderListener<T>	A listener that will be called in order for every message received.
RedeliveryBackoff	Interface for custom message is negativeAcked policy, users can specify a RedeliveryBackoff for a consumer.
RegexSubscriptionMode	When subscribing to topics using a regular expression, one can specify to only pick a certain type of topics.
Schema<T>	Message schema definition.
SchemaSerializationException	Schema serialization exception.
ServiceUrlProvider	The provider to provide the service url.
SizeUnit	Size unit converter.
SubscriptionInitialPosition	When creating a consumer, if the subscription does not exist, a new subscription will be created.
SubscriptionMode	Types of subscription mode supported by Pulsar.
SubscriptionType	Types of subscription supported by Pulsar.
TableView<T>
TableViewBuilder<T>	TableViewBuilder is used to configure and create instances of TableView.
TopicConsumerBuilder<T>	TopicConsumerBuilder is used to configure topic specific options to override those set at the ConsumerBuilder level.
TopicMessageId	The MessageId used for a consumer that subscribes multiple topics or partitioned topics.
TopicMetadata	Metadata of a topic that can be used for message routing.
TransactionIsolationLevel
TypedMessageBuilder<T>	Message builder that constructs a message to be published through a producer.