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.

timeout

int timeout

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

timeoutUnit

TimeUnit timeoutUnit

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