Serialized Form (Pulsar Client Java 2.2.0 API)

Package org.apache.pulsar.client.api
- Class org.apache.pulsar.client.api.ClientConfiguration extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - confData
```
ClientConfigurationData confData
```
      Deprecated.
- Class org.apache.pulsar.client.api.ConsumerConfiguration extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - conf
```
ConsumerConfigurationData<T> conf
```
      Deprecated.
    - initializeSubscriptionOnLatest
```
boolean initializeSubscriptionOnLatest
```
      Deprecated.
- Class org.apache.pulsar.client.api.ProducerConfiguration extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - conf
```
ProducerConfigurationData conf
```
      Deprecated.
- Class org.apache.pulsar.client.api.PulsarClientException extends IOException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.AlreadyClosedException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.AuthenticationException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.AuthorizationException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.BrokerMetadataException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.BrokerPersistenceException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.ChecksumException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.ConnectException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.ConsumerBusyException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.CryptoException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.GettingAuthenticationDataException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.InvalidConfigurationException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.InvalidMessageException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.InvalidServiceURL extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.InvalidTopicNameException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.LookupException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.NotConnectedException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.NotFoundException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.NotSupportedException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.ProducerBlockedQuotaExceededError extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.ProducerBlockedQuotaExceededException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.ProducerBusyException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.ProducerQueueIsFullError extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.TimeoutException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.TooManyRequestsException extends PulsarClientException.LookupException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.TopicTerminatedException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.PulsarClientException.UnsupportedAuthenticationException extends PulsarClientException implements Serializable
- Class org.apache.pulsar.client.api.ReaderConfiguration extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - conf
```
ReaderConfigurationData<T> conf
```
      Deprecated.
- Class org.apache.pulsar.client.api.SchemaSerializationException extends RuntimeException implements Serializable
Package org.apache.pulsar.client.impl
- Class org.apache.pulsar.client.impl.BatchMessageIdImpl extends MessageIdImpl implements Serializable
  - Serialized Fields
    - batchIndex
```
int batchIndex
```
    - acker
```
org.apache.pulsar.client.impl.BatchMessageAcker acker
```
- Class org.apache.pulsar.client.impl.ConsumerStatsDisabled extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - stat
```
io.netty.util.TimerTask stat
```
    - statTimeout
```
io.netty.util.Timeout statTimeout
```
    - consumer
```
ConsumerImpl<T> consumer
```
    - pulsarClient
```
PulsarClientImpl pulsarClient
```
    - oldTime
```
long oldTime
```
    - statsIntervalSeconds
```
long statsIntervalSeconds
```
    - numMsgsReceived
```
LongAdder numMsgsReceived
```
    - numBytesReceived
```
LongAdder numBytesReceived
```
    - numReceiveFailed
```
LongAdder numReceiveFailed
```
    - numAcksSent
```
LongAdder numAcksSent
```
    - numAcksFailed
```
LongAdder numAcksFailed
```
    - totalMsgsReceived
```
LongAdder totalMsgsReceived
```
    - totalBytesReceived
```
LongAdder totalBytesReceived
```
    - totalReceiveFailed
```
LongAdder totalReceiveFailed
```
    - totalAcksSent
```
LongAdder totalAcksSent
```
    - totalAcksFailed
```
LongAdder totalAcksFailed
```
    - receivedMsgsRate
```
double receivedMsgsRate
```
    - receivedBytesRate
```
double receivedBytesRate
```
- Class org.apache.pulsar.client.impl.MessageIdImpl extends Object implements Serializable
  - Serialized Fields
    - ledgerId
```
long ledgerId
```
    - entryId
```
long entryId
```
    - partitionIndex
```
int partitionIndex
```
- Class org.apache.pulsar.client.impl.MessageRouterBase extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hash
```
Hash hash
```
- Class org.apache.pulsar.client.impl.ProducerStatsDisabled extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.pulsar.client.impl.ProducerStatsRecorderImpl extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - stat
```
io.netty.util.TimerTask stat
```
    - statTimeout
```
io.netty.util.Timeout statTimeout
```
    - producer
```
ProducerImpl<T> producer
```
    - pulsarClient
```
PulsarClientImpl pulsarClient
```
    - oldTime
```
long oldTime
```
    - statsIntervalSeconds
```
long statsIntervalSeconds
```
    - numMsgsSent
```
LongAdder numMsgsSent
```
    - numBytesSent
```
LongAdder numBytesSent
```
    - numSendFailed
```
LongAdder numSendFailed
```
    - numAcksReceived
```
LongAdder numAcksReceived
```
    - totalMsgsSent
```
LongAdder totalMsgsSent
```
    - totalBytesSent
```
LongAdder totalBytesSent
```
    - totalSendFailed
```
LongAdder totalSendFailed
```
    - totalAcksReceived
```
LongAdder totalAcksReceived
```
    - ds
```
com.yahoo.sketches.quantiles.DoublesSketch ds
```
    - sendMsgsRate
```
double sendMsgsRate
```
    - sendBytesRate
```
double sendBytesRate
```
    - latencyPctValues
```
double[] latencyPctValues
```
- Class org.apache.pulsar.client.impl.RoundRobinPartitionMessageRouterImpl extends MessageRouterBase implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionIndex
```
int partitionIndex
```
    - startPtnIdx
```
int startPtnIdx
```
    - isBatchingEnabled
```
boolean isBatchingEnabled
```
    - maxBatchingDelayMs
```
long maxBatchingDelayMs
```
    - clock
```
Clock clock
```
- Class org.apache.pulsar.client.impl.SinglePartitionMessageRouterImpl extends MessageRouterBase implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionIndex
```
int partitionIndex
```
- Class org.apache.pulsar.client.impl.TopicMessageIdImpl extends Object implements Serializable
  - Serialized Fields
    - topicPartitionName
```
String topicPartitionName
```
      This topicPartitionName is get from ConsumerImpl, it contains partition part.
    - topicName
```
String topicName
```
    - messageId
```
MessageId messageId
```
- Class org.apache.pulsar.client.impl.TypedMessageBuilderImpl extends Object implements Serializable
  - Serialized Fields
    - producer
```
ProducerBase<T> producer
```
    - msgMetadataBuilder
```
org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata.Builder msgMetadataBuilder
```
    - schema
```
org.apache.pulsar.client.api.Schema<T> schema
```
    - content
```
ByteBuffer content
```
Package org.apache.pulsar.client.impl.auth
- Class org.apache.pulsar.client.impl.auth.AuthenticationBasic extends Object implements Serializable
  - Serialized Fields
    - userId
```
String userId
```
    - password
```
String password
```
- Class org.apache.pulsar.client.impl.auth.AuthenticationDataBasic extends Object implements Serializable
  - Serialized Fields
    - httpAuthToken
```
String httpAuthToken
```
    - commandAuthToken
```
String commandAuthToken
```
- Class org.apache.pulsar.client.impl.auth.AuthenticationDataNull extends Object implements Serializable
- Class org.apache.pulsar.client.impl.auth.AuthenticationDataTls extends Object implements Serializable
  - Serialized Fields
    - certificates
```
X509Certificate[] certificates
```
    - privateKey
```
PrivateKey privateKey
```
- Class org.apache.pulsar.client.impl.auth.AuthenticationDisabled extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nullData
```
AuthenticationDataProvider nullData
```
- Class org.apache.pulsar.client.impl.auth.AuthenticationTls extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - certFilePath
```
String certFilePath
```
    - keyFilePath
```
String keyFilePath
```

Package org.apache.pulsar.client.impl.conf

Class org.apache.pulsar.client.impl.conf.ClientConfigurationData extends Object implements Serializable

serialVersionUID:

1L
- Serialized Fields
  - serviceUrl
```
String serviceUrl
```
  - serviceUrlProvider
```
ServiceUrlProvider serviceUrlProvider
```
  - authentication
```
Authentication authentication
```
  - operationTimeoutMs
```
long operationTimeoutMs
```
  - statsIntervalSeconds
```
long statsIntervalSeconds
```
  - numIoThreads
```
int numIoThreads
```
  - numListenerThreads
```
int numListenerThreads
```
  - connectionsPerBroker
```
int connectionsPerBroker
```
  - useTcpNoDelay
```
boolean useTcpNoDelay
```
  - useTls
```
boolean useTls
```
  - tlsTrustCertsFilePath
```
String tlsTrustCertsFilePath
```
  - tlsAllowInsecureConnection
```
boolean tlsAllowInsecureConnection
```
  - tlsHostnameVerificationEnable
```
boolean tlsHostnameVerificationEnable
```
  - concurrentLookupRequest
```
int concurrentLookupRequest
```
  - maxLookupRequest
```
int maxLookupRequest
```
  - maxNumberOfRejectedRequestPerConnection
```
int maxNumberOfRejectedRequestPerConnection
```
  - keepAliveIntervalSeconds
```
int keepAliveIntervalSeconds
```

Class org.apache.pulsar.client.impl.conf.ConsumerConfigurationData extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

topicNames
```
Set<E> topicNames
```
topicsPattern
```
Pattern topicsPattern
```
subscriptionName
```
String subscriptionName
```
subscriptionType
```
SubscriptionType subscriptionType
```
messageListener
```
MessageListener<T> messageListener
```

consumerEventListener

ConsumerEventListener consumerEventListener

receiverQueueSize
```
int receiverQueueSize
```
acknowledgementsGroupTimeMicros
```
long acknowledgementsGroupTimeMicros
```

maxTotalReceiverQueueSizeAcrossPartitions

int maxTotalReceiverQueueSizeAcrossPartitions

consumerName
```
String consumerName
```
ackTimeoutMillis
```
long ackTimeoutMillis
```
priorityLevel
```
int priorityLevel
```
cryptoKeyReader
```
CryptoKeyReader cryptoKeyReader
```

cryptoFailureAction

ConsumerCryptoFailureAction cryptoFailureAction

properties
```
SortedMap<K,V> properties
```
readCompacted
```
boolean readCompacted
```

subscriptionInitialPosition

SubscriptionInitialPosition subscriptionInitialPosition

patternAutoDiscoveryPeriod
```
int patternAutoDiscoveryPeriod
```

subscriptionTopicsMode

org.apache.pulsar.common.api.proto.PulsarApi.CommandGetTopicsOfNamespace.Mode subscriptionTopicsMode

deadLetterPolicy
```
DeadLetterPolicy deadLetterPolicy
```

Class org.apache.pulsar.client.impl.conf.ProducerConfigurationData extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

topicName
```
String topicName
```
producerName
```
String producerName
```
sendTimeoutMs
```
long sendTimeoutMs
```
blockIfQueueFull
```
boolean blockIfQueueFull
```
maxPendingMessages
```
int maxPendingMessages
```
maxPendingMessagesAcrossPartitions
```
int maxPendingMessagesAcrossPartitions
```
messageRoutingMode
```
MessageRoutingMode messageRoutingMode
```
hashingScheme
```
HashingScheme hashingScheme
```

cryptoFailureAction

ProducerCryptoFailureAction cryptoFailureAction

customMessageRouter
```
MessageRouter customMessageRouter
```
batchingMaxPublishDelayMicros
```
long batchingMaxPublishDelayMicros
```
batchingMaxMessages
```
int batchingMaxMessages
```
batchingEnabled
```
boolean batchingEnabled
```
cryptoKeyReader
```
CryptoKeyReader cryptoKeyReader
```
encryptionKeys
```
Set<E> encryptionKeys
```
compressionType
```
CompressionType compressionType
```
initialSequenceId
```
Long initialSequenceId
```
properties
```
SortedMap<K,V> properties
```

Class org.apache.pulsar.client.impl.conf.ReaderConfigurationData extends Object implements Serializable
- Serialized Fields
  - topicName
```
String topicName
```
  - startMessageId
```
MessageId startMessageId
```
  - receiverQueueSize
```
int receiverQueueSize
```
  - readerListener
```
ReaderListener<T> readerListener
```
  - readerName
```
String readerName
```
  - subscriptionRolePrefix
```
String subscriptionRolePrefix
```
  - cryptoKeyReader
```
CryptoKeyReader cryptoKeyReader
```
  - cryptoFailureAction
```
ConsumerCryptoFailureAction cryptoFailureAction
```
  - readCompacted
```
boolean readCompacted
```

Serialized Form

Package org.apache.pulsar.client.api

Class org.apache.pulsar.client.api.ClientConfiguration extends Object implements Serializable

Serialized Fields

confData

Class org.apache.pulsar.client.api.ConsumerConfiguration extends Object implements Serializable

Serialized Fields

conf

initializeSubscriptionOnLatest

Class org.apache.pulsar.client.api.ProducerConfiguration extends Object implements Serializable

Serialized Fields

conf

Class org.apache.pulsar.client.api.PulsarClientException extends IOException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.AlreadyClosedException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.AuthenticationException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.AuthorizationException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.BrokerMetadataException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.BrokerPersistenceException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.ChecksumException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.ConnectException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.ConsumerBusyException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.CryptoException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.GettingAuthenticationDataException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.InvalidConfigurationException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.InvalidMessageException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.InvalidServiceURL extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.InvalidTopicNameException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.LookupException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.NotConnectedException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.NotFoundException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.NotSupportedException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.ProducerBlockedQuotaExceededError extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.ProducerBlockedQuotaExceededException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.ProducerBusyException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.ProducerQueueIsFullError extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.TimeoutException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.TooManyRequestsException extends PulsarClientException.LookupException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.TopicTerminatedException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.PulsarClientException.UnsupportedAuthenticationException extends PulsarClientException implements Serializable

Class org.apache.pulsar.client.api.ReaderConfiguration extends Object implements Serializable

Serialized Fields

conf

Class org.apache.pulsar.client.api.SchemaSerializationException extends RuntimeException implements Serializable

Package org.apache.pulsar.client.impl

Class org.apache.pulsar.client.impl.BatchMessageIdImpl extends MessageIdImpl implements Serializable

Serialized Fields

batchIndex

acker

Class org.apache.pulsar.client.impl.ConsumerStatsDisabled extends Object implements Serializable

Class org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl extends Object implements Serializable

Serialized Fields

stat

statTimeout

consumer

pulsarClient

oldTime

statsIntervalSeconds

numMsgsReceived

numBytesReceived

numReceiveFailed

numAcksSent

numAcksFailed

totalMsgsReceived

totalBytesReceived

totalReceiveFailed

totalAcksSent

totalAcksFailed

receivedMsgsRate

receivedBytesRate

Class org.apache.pulsar.client.impl.MessageIdImpl extends Object implements Serializable

Serialized Fields

ledgerId

entryId

partitionIndex

Class org.apache.pulsar.client.impl.MessageRouterBase extends Object implements Serializable

Serialized Fields

hash

Class org.apache.pulsar.client.impl.ProducerStatsDisabled extends Object implements Serializable

Class org.apache.pulsar.client.impl.ProducerStatsRecorderImpl extends Object implements Serializable

Serialized Fields