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.DummyCryptoKeyReaderImpl

class DummyCryptoKeyReaderImpl extends Object implements Serializable

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.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

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