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.A binary-protocol
CommandAuthChallenge payload handed to a
BinaryAuthChallengeHandler (PIP-478).Pluggable authentication provider for the Pulsar v5 client (PIP-478).
The per-call context for binary-protocol authentication (PIP-478).
Factory for creating common authentication providers.
Runtime services handed to
Authentication.initializeAsync(AuthenticationInitContext) once when the client is built
(PIP-478).Backoff configuration for broker reconnection attempts.
Builder for
BackoffPolicy.Configuration for producer message batching.
Builder for
BatchingPolicy.Capability: multi-round challenge/response (SASL-style and custom protocols) for the Pulsar binary
protocol (PIP-478).
The binary-protocol credential: the
auth_data bytes for CommandConnect (PIP-478).Capability: single-pass credential exchange for the Pulsar binary protocol (PIP-478).
The reply from
BinaryAuthChallengeHandler.respondToChallengeAsync(AuthenticationCallContext, AuthChallenge) — the bytes for the next
CommandAuthResponse (PIP-478).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.The framework-owned runtime services a
PulsarClient late-binds into its authentication driver
once the client instance exists (PIP-478).Implemented by an authentication driver that wants the framework's real client services late-bound
into it after the
PulsarClient is constructed (PIP-478).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()).The per-call context for HTTP authentication (PIP-478).
Capability: SASL-style multi-round challenge/response over HTTP (PIP-478).
HTTP authentication headers an implementation produces for an outgoing request (and, for
challenge/response, the headers carrying a server's challenge) (PIP-478).
Capability: single-pass credential exchange for the Pulsar HTTP transport (PIP-478).
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.
Transient failure while acquiring a credential (token endpoint timeout, ZTS unavailable).
The requested authentication capability is not supported by the plugin (used by the legacy v4
adapter when a wrapped v4 provider returns null/false from the corresponding
hasData*
method).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.
Convenience composite: a single-pass credential served over both transports (PIP-478).
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.
A Pulsar transaction handle.
Transaction configuration for the Pulsar client.
Builder for
TransactionPolicy.Implemented by a legacy v4
org.apache.pulsar.client.api.Authentication that owns a v5-native
body, so the client can drive the v5 body directly instead of bridging the v4 plugin (PIP-478).