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

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.

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 org.apache.pulsar.client.api.PulsarClientException

class PulsarClientException extends IOException implements Serializable

Serialized Fields

previous

Collection<Throwable> previous

sequenceId

long sequenceId

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

class AlreadyClosedException extends PulsarClientException implements Serializable

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

class AuthenticationException extends PulsarClientException implements Serializable

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

class AuthorizationException extends PulsarClientException implements Serializable

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

class BrokerMetadataException extends PulsarClientException implements Serializable

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

class BrokerPersistenceException extends PulsarClientException implements Serializable

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

class ChecksumException extends PulsarClientException implements Serializable

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

class ConnectException extends PulsarClientException implements Serializable

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

class ConsumerAssignException extends PulsarClientException implements Serializable

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

class ConsumerBusyException extends PulsarClientException implements Serializable

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

class CryptoException extends PulsarClientException implements Serializable

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

class FeatureNotSupportedException extends PulsarClientException.NotSupportedException implements Serializable

Serialized Fields

failedFeatureCheck

PulsarClientException.FailedFeatureCheck failedFeatureCheck

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

class GettingAuthenticationDataException extends PulsarClientException implements Serializable

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

class IncompatibleSchemaException extends PulsarClientException implements Serializable

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

class InvalidConfigurationException extends PulsarClientException implements Serializable

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

class InvalidMessageException extends PulsarClientException implements Serializable

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

class InvalidServiceURL extends PulsarClientException implements Serializable

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

class InvalidTopicNameException extends PulsarClientException implements Serializable

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

class LookupException extends PulsarClientException implements Serializable

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

class MemoryBufferIsFullError extends PulsarClientException implements Serializable

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

class MessageAcknowledgeException extends PulsarClientException implements Serializable

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

class NotAllowedException extends PulsarClientException implements Serializable

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

class NotConnectedException extends PulsarClientException implements Serializable

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

class NotFoundException extends PulsarClientException implements Serializable

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

class NotSupportedException extends PulsarClientException implements Serializable

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

class ProducerBlockedQuotaExceededError extends PulsarClientException implements Serializable

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

class ProducerBlockedQuotaExceededException extends PulsarClientException implements Serializable

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

class ProducerBusyException extends PulsarClientException implements Serializable

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

class ProducerFencedException extends PulsarClientException implements Serializable

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

class ProducerQueueIsFullError extends PulsarClientException implements Serializable

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

class SubscriptionNotFoundException extends PulsarClientException implements Serializable

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

class TimeoutException extends PulsarClientException implements Serializable

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

class TooManyRequestsException extends PulsarClientException.LookupException implements Serializable

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

class TopicDoesNotExistException extends PulsarClientException implements Serializable

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

class TopicMigrationException extends PulsarClientException implements Serializable

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

class TopicTerminatedException extends PulsarClientException implements Serializable

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

class TransactionConflictException extends PulsarClientException implements Serializable

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

class TransactionHasOperationFailedException extends PulsarClientException implements Serializable

Exception 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 org.apache.pulsar.client.api.SchemaSerializationException

class SchemaSerializationException extends RuntimeException implements Serializable

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

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

class TransactionBufferClientException extends IOException implements Serializable

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

class ReachMaxPendingOpsException extends TransactionBufferClientException implements Serializable

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

class RequestTimeoutException extends TransactionBufferClientException implements Serializable

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

class TransactionCoordinatorClientException extends IOException implements Serializable

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

class CoordinatorClientStateException extends TransactionCoordinatorClientException implements Serializable

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

class CoordinatorNotFoundException extends TransactionCoordinatorClientException implements Serializable

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

class InvalidTxnStatusException extends TransactionCoordinatorClientException implements Serializable

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

class MetaStoreHandlerNotExistsException extends TransactionCoordinatorClientException implements Serializable

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

class MetaStoreHandlerNotReadyException extends TransactionCoordinatorClientException implements Serializable

Exception 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