All Classes and Interfaces
Class
Description
Asynchronous view of a
CheckpointConsumer.Asynchronous message builder, obtained from
AsyncProducer.newMessage().Asynchronous view of a
Producer.Asynchronous view of a
QueueConsumer.Asynchronous view of a
StreamConsumer.Asynchronous view of a
Transaction.Pluggable authentication provider for Pulsar clients.
Provides authentication credentials for different transport mechanisms.
Factory for creating common authentication providers.
Backoff configuration for broker reconnection attempts.
Builder for
BackoffPolicy.Configuration for producer message batching.
Builder for
BatchingPolicy.An opaque, serializable position vector representing a consistent point across all
internal hash-range segments of a topic.
An unmanaged consumer designed for connector frameworks (Flink, Spark, etc.).
Builder for configuring and creating a
CheckpointConsumer.Configuration for chunking large messages that exceed the broker's max message size.
Builder for
ChunkingPolicy.Compression configuration for producer message payloads.
Builder for
CompressionPolicy.Compression codec used for message payloads.
Connection-level settings for the Pulsar client.
Builder for
ConnectionPolicy.Action a consumer takes when message decryption fails (e.g.
Consumer-side end-to-end decryption configuration.
Builder for
ConsumerEncryptionPolicy.Convenience interface for implementations that serve both public keys (for
producer-side encryption) and private keys (for consumer-side decryption) — for
example, a single PEM-file-backed key store used by both sides of an in-process
round trip.
Configuration for the dead letter queue mechanism.
Builder for
DeadLetterPolicy.A single encryption / decryption key returned by a
PublicKeyProvider or
PrivateKeyProvider.A named field of a
GenericRecord.A schema-less view over a decoded message value, used when the value's schema is discovered at
runtime rather than known at compile time (see
Schema.autoConsume()).A key/value pair, used as the native object of a
GenericRecord whose schema type is
SchemaType.KEY_VALUE.A type-safe representation of a memory size in bytes.
An immutable message received from a Pulsar topic.
Synchronous message builder, obtained from
Producer.newMessage().Opaque, immutable identifier for a message within a topic.
Common message metadata that can be set on any outgoing message.
A batch of messages received from a consumer.
Batteries-included key provider that loads PEM-encoded keys from local files.
Builder for
PemFileKeyProvider.Consumer-side SPI: load a private key by name for end-to-end message decryption.
Optional safety net for slow / stalled queue consumers: if the application doesn't
process and acknowledge a delivered message within
timeout, the client
gives up on that delivery and asks the broker to redeliver it (to this consumer or,
on a Shared subscription, to another consumer in the group).Builder for
ProcessingTimeoutPolicy.A producer publishes messages to a Pulsar topic.
Access mode for a producer on a topic.
Builder for configuring and creating a
Producer.Action a producer takes when message encryption fails (e.g.
Producer-side end-to-end encryption configuration.
Builder for
ProducerEncryptionPolicy.Protocol used when connecting through a proxy.
Producer-side SPI: load a public key by name for end-to-end message encryption.
Entry point for the Pulsar client.
Builder for configuring and creating a
PulsarClient.Base exception for all Pulsar client operations.
Service Provider Interface for the Pulsar client implementation.
Lazy initialization holder for the provider singleton.
A consumer for queue (unordered) consumption with broker-managed position tracking.
Builder for configuring and creating a
QueueConsumer.Defines how message values are serialized to bytes and deserialized from bytes.
Describes a schema for broker-side schema negotiation and compatibility checks.
Types of schema supported by Pulsar.
A consumer for streaming (ordered) consumption with broker-managed position tracking.
Builder for configuring and creating a
StreamConsumer.Initial position for a new subscription that has no existing cursor.
TLS configuration for the Pulsar client connection.
Builder for
TlsPolicy.A Pulsar transaction handle.
Transaction configuration for the Pulsar client.
Builder for
TransactionPolicy.