Serialized Form

Package org.apache.pulsar.client.api

Class org.apache.pulsar.client.api.BatchReceivePolicy

class BatchReceivePolicy extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

maxNumBytes

int maxNumBytes

Max bytes of messages for a single batch receive, 0 or negative means no limit.

maxNumMessages

int maxNumMessages

Max number of messages for a single batch receive, 0 or negative means no limit.

messagesFromMultiTopicsEnabled

boolean messagesFromMultiTopicsEnabled

If it is false, one time `batchReceive()` only can receive the single topic messages, the max messages and max size will not be strictly followed. (default: true).

timeout

int timeout

timeout for waiting for enough messages(enough number or enough bytes).

timeoutUnit

TimeUnit timeoutUnit

Class org.apache.pulsar.client.api.DeadLetterPolicy

class DeadLetterPolicy extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

deadLetterProducerBuilderCustomizer

DeadLetterProducerBuilderCustomizer deadLetterProducerBuilderCustomizer

Customizer for configuring the producer builder for the dead letter topic.

This field holds a function that allows the caller to customize the producer builder settings for the dead letter topic before the producer is created. Using the provided context, implementations can perform specific adjustments that ensure the dead letter queue operates with the appropriate configurations tailored for handling undeliverable messages.

deadLetterTopic

String deadLetterTopic

Name of the dead topic where the failing messages will be sent.

initialSubscriptionName

String initialSubscriptionName

Name of the initial subscription name of the dead letter topic. If this field is not set, the initial subscription for the dead letter topic will not be created. If this field is set but the broker's `allowAutoSubscriptionCreation` is disabled, the DLQ producer will fail to be created.

maxRedeliverCount

int maxRedeliverCount

Maximum number of times that a message will be redelivered before being sent to the dead letter queue.

retryLetterProducerBuilderCustomizer

DeadLetterProducerBuilderCustomizer retryLetterProducerBuilderCustomizer

Customizer for configuring the producer builder for the retry letter topic.

This field holds a function that allows the caller to customize the producer builder settings for the retry letter topic before the producer is created. The customization logic can use the provided context (which includes input topic and subscription details) to adjust configurations such as timeouts, batching, or message routing.

retryLetterTopic

String retryLetterTopic

Name of the retry topic where the failing messages will be sent.

Class org.apache.pulsar.client.api.DummyCryptoKeyReaderImpl

class DummyCryptoKeyReaderImpl extends Object implements Serializable

Class org.apache.pulsar.client.api.KeySharedPolicy

class KeySharedPolicy extends Object implements Serializable

Serialized Fields

allowOutOfOrderDelivery

boolean allowOutOfOrderDelivery

keySharedMode

KeySharedMode keySharedMode

Class org.apache.pulsar.client.api.KeySharedPolicy.KeySharedPolicyAutoSplit

class KeySharedPolicyAutoSplit extends KeySharedPolicy implements Serializable

serialVersionUID:

1L

Class org.apache.pulsar.client.api.KeySharedPolicy.KeySharedPolicySticky

class KeySharedPolicySticky extends KeySharedPolicy implements Serializable

serialVersionUID:

1L

Serialized Fields

ranges

List<Range> ranges

Exception Class org.apache.pulsar.client.api.PulsarClientException

class PulsarClientException extends IOException implements Serializable

Serialized Fields

previousExceptionAttempt

AtomicInteger previousExceptionAttempt

sequenceId

long sequenceId

Exception Class org.apache.pulsar.client.api.PulsarClientException.AlreadyClosedException

class AlreadyClosedException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.AuthenticationException

class AuthenticationException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.AuthorizationException

class AuthorizationException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.BrokerMetadataException

class BrokerMetadataException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.BrokerPersistenceException

class BrokerPersistenceException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.ChecksumException

class ChecksumException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.ConnectException

class ConnectException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.ConsumerAssignException

class ConsumerAssignException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.ConsumerBusyException

class ConsumerBusyException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.CryptoException

class CryptoException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.FeatureNotSupportedException

class FeatureNotSupportedException extends PulsarClientException.NotSupportedException implements Serializable

Serialized Fields

failedFeatureCheck

PulsarClientException.FailedFeatureCheck failedFeatureCheck

Exception Class org.apache.pulsar.client.api.PulsarClientException.GettingAuthenticationDataException

class GettingAuthenticationDataException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.IncompatibleSchemaException

class IncompatibleSchemaException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.InvalidConfigurationException

class InvalidConfigurationException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.InvalidMessageException

class InvalidMessageException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.InvalidServiceURL

class InvalidServiceURL extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.InvalidTopicNameException

class InvalidTopicNameException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.LookupException

class LookupException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.MemoryBufferIsFullError

class MemoryBufferIsFullError extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.MessageAcknowledgeException

class MessageAcknowledgeException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.NotAllowedException

class NotAllowedException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.NotConnectedException

class NotConnectedException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.NotFoundException

class NotFoundException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.NotSupportedException

class NotSupportedException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.ProducerBlockedQuotaExceededError

class ProducerBlockedQuotaExceededError extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.ProducerBlockedQuotaExceededException

class ProducerBlockedQuotaExceededException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.ProducerBusyException

class ProducerBusyException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.ProducerFencedException

class ProducerFencedException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.ProducerQueueIsFullError

class ProducerQueueIsFullError extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.SubscriptionNotFoundException

class SubscriptionNotFoundException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.TimeoutException

class TimeoutException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.TooManyRequestsException

class TooManyRequestsException extends PulsarClientException.LookupException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.TopicDoesNotExistException

class TopicDoesNotExistException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.TopicMigrationException

class TopicMigrationException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.TopicTerminatedException

class TopicTerminatedException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.TransactionConflictException

class TransactionConflictException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.TransactionHasOperationFailedException

class TransactionHasOperationFailedException extends PulsarClientException implements Serializable

Exception Class org.apache.pulsar.client.api.PulsarClientException.UnsupportedAuthenticationException

class UnsupportedAuthenticationException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.Range

class Range extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

end

int end

start

int start

Exception Class org.apache.pulsar.client.api.SchemaSerializationException

class SchemaSerializationException extends RuntimeException implements Serializable

Package org.apache.pulsar.client.api.transaction

Exception Class org.apache.pulsar.client.api.transaction.TransactionBufferClientException

class TransactionBufferClientException extends IOException implements Serializable

Exception Class org.apache.pulsar.client.api.transaction.TransactionBufferClientException.ReachMaxPendingOpsException

class ReachMaxPendingOpsException extends TransactionBufferClientException implements Serializable

Exception Class org.apache.pulsar.client.api.transaction.TransactionBufferClientException.RequestTimeoutException

class RequestTimeoutException extends TransactionBufferClientException implements Serializable

Exception Class org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException

class TransactionCoordinatorClientException extends IOException implements Serializable

Exception Class org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException.CoordinatorClientStateException

class CoordinatorClientStateException extends TransactionCoordinatorClientException implements Serializable

Exception Class org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException.CoordinatorNotFoundException

class CoordinatorNotFoundException extends TransactionCoordinatorClientException implements Serializable

Exception Class org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException.InvalidTxnStatusException

class InvalidTxnStatusException extends TransactionCoordinatorClientException implements Serializable

Exception Class org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException.MetaStoreHandlerNotExistsException

class MetaStoreHandlerNotExistsException extends TransactionCoordinatorClientException implements Serializable

Exception Class org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException.MetaStoreHandlerNotReadyException

class MetaStoreHandlerNotReadyException extends TransactionCoordinatorClientException implements Serializable

Exception Class org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException.TransactionNotFoundException

class TransactionNotFoundException extends TransactionCoordinatorClientException implements Serializable

Class org.apache.pulsar.client.api.transaction.TxnID

class TxnID extends Object implements Serializable

serialVersionUID:

0L

Serialized Fields

leastSigBits

long leastSigBits

mostSigBits

long mostSigBits