Serialized Form (Pulsar Client Java 2.5.2 API)

Package org.apache.pulsar.client.impl
- Class org.apache.pulsar.client.impl.BatchMessageIdImpl extends MessageIdImpl implements Serializable
  - Serialized Fields
    - batchIndex
```
int batchIndex
```
- 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
```
    - numBatchReceiveFailed
```
LongAdder numBatchReceiveFailed
```
    - numAcksSent
```
LongAdder numAcksSent
```
    - numAcksFailed
```
LongAdder numAcksFailed
```
    - totalMsgsReceived
```
LongAdder totalMsgsReceived
```
    - totalBytesReceived
```
LongAdder totalBytesReceived
```
    - totalReceiveFailed
```
LongAdder totalReceiveFailed
```
    - totalBatchReceiveFailed
```
LongAdder totalBatchReceiveFailed
```
    - totalAcksSent
```
LongAdder totalAcksSent
```
    - totalAcksFailed
```
LongAdder totalAcksFailed
```
    - receivedMsgsRate
```
double receivedMsgsRate
```
    - receivedBytesRate
```
double receivedBytesRate
```
- Class org.apache.pulsar.client.impl.DefaultBatcherBuilder extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.pulsar.client.impl.KeyBasedBatcherBuilder extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- 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.MultiMessageIdImpl extends Object implements Serializable
  - Serialized Fields
    - map
```
Map<K,V> map
```
- 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
```
    - partitionSwitchMs
```
long partitionSwitchMs
```
    - 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
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - producer
```
ProducerBase<T> producer
```
    - msgMetadataBuilder
```
PulsarApi.MessageMetadata.Builder msgMetadataBuilder
```
    - schema
```
Schema<T> schema
```
    - content
```
ByteBuffer content
```
    - txn
```
TransactionImpl txn
```
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.AuthenticationDataKeyStoreTls extends Object implements Serializable
  - Serialized Fields
    - keyStoreParams
```
KeyStoreParams keyStoreParams
```
- 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
    - tlsCertificates
```
X509Certificate[] tlsCertificates
```
    - tlsPrivateKey
```
PrivateKey tlsPrivateKey
```
    - certFile
```
FileModifiedTimeUpdater certFile
```
    - keyFile
```
FileModifiedTimeUpdater keyFile
```
    - certStream
```
InputStream certStream
```
    - keyStream
```
InputStream keyStream
```
    - certStreamProvider
```
Supplier<T> certStreamProvider
```
    - keyStreamProvider
```
Supplier<T> keyStreamProvider
```
- Class org.apache.pulsar.client.impl.auth.AuthenticationDataToken extends Object implements Serializable
  - Serialized Fields
    - tokenSupplier
```
Supplier<T> tokenSupplier
```
- 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.AuthenticationKeyStoreTls extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keyStoreParams
```
KeyStoreParams keyStoreParams
```
- Class org.apache.pulsar.client.impl.auth.AuthenticationTls extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - certFilePath
```
String certFilePath
```
    - keyFilePath
```
String keyFilePath
```
    - certStreamProvider
```
Supplier<T> certStreamProvider
```
    - keyStreamProvider
```
Supplier<T> keyStreamProvider
```
- Class org.apache.pulsar.client.impl.auth.AuthenticationToken extends Object implements Serializable
  - Serialized Fields
    - tokenSupplier
```
Supplier<T> tokenSupplier
```

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
```
authPluginClassName
```
String authPluginClassName
```
authParams
```
String authParams
```
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
```
connectionTimeoutMs
```
int connectionTimeoutMs
```
requestTimeoutMs
```
int requestTimeoutMs
```
initialBackoffIntervalNanos
```
long initialBackoffIntervalNanos
```
maxBackoffIntervalNanos
```
long maxBackoffIntervalNanos
```
useKeyStoreTls
```
boolean useKeyStoreTls
```
sslProvider
```
String sslProvider
```
tlsTrustStoreType
```
String tlsTrustStoreType
```
tlsTrustStorePath
```
String tlsTrustStorePath
```
tlsTrustStorePassword
```
String tlsTrustStorePassword
```
tlsCiphers
```
Set<E> tlsCiphers
```
tlsProtocols
```
Set<E> tlsProtocols
```
clock
```
Clock clock
```

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
```
subscriptionMode
```
SubscriptionMode subscriptionMode
```
messageListener
```
MessageListener<T> messageListener
```

consumerEventListener

ConsumerEventListener consumerEventListener

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

maxTotalReceiverQueueSizeAcrossPartitions

int maxTotalReceiverQueueSizeAcrossPartitions

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

messageCrypto

MessageCrypto<MetadataT,BuilderT> messageCrypto

cryptoFailureAction

ConsumerCryptoFailureAction cryptoFailureAction

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

subscriptionInitialPosition

SubscriptionInitialPosition subscriptionInitialPosition

patternAutoDiscoveryPeriod
```
int patternAutoDiscoveryPeriod
```

regexSubscriptionMode

RegexSubscriptionMode regexSubscriptionMode

deadLetterPolicy
```
DeadLetterPolicy deadLetterPolicy
```
batchReceivePolicy
```
BatchReceivePolicy batchReceivePolicy
```
autoUpdatePartitions
```
boolean autoUpdatePartitions
```
replicateSubscriptionState
```
boolean replicateSubscriptionState
```
resetIncludeHead
```
boolean resetIncludeHead
```
keySharedPolicy
```
KeySharedPolicy keySharedPolicy
```

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

batchingPartitionSwitchFrequencyByPublishDelay

int batchingPartitionSwitchFrequencyByPublishDelay

batchingMaxMessages
```
int batchingMaxMessages
```
batchingMaxBytes
```
int batchingMaxBytes
```
batchingEnabled
```
boolean batchingEnabled
```
batcherBuilder
```
BatcherBuilder batcherBuilder
```
cryptoKeyReader
```
CryptoKeyReader cryptoKeyReader
```

messageCrypto

MessageCrypto<MetadataT,BuilderT> messageCrypto

encryptionKeys
```
Set<E> encryptionKeys
```
compressionType
```
CompressionType compressionType
```
initialSequenceId
```
Long initialSequenceId
```
autoUpdatePartitions
```
boolean autoUpdatePartitions
```
multiSchema
```
boolean multiSchema
```
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
```

startMessageFromRollbackDurationInSec

long startMessageFromRollbackDurationInSec

receiverQueueSize
```
int receiverQueueSize
```
readerListener
```
ReaderListener<T> readerListener
```
readerName
```
String readerName
```
subscriptionRolePrefix
```
String subscriptionRolePrefix
```
cryptoKeyReader
```
CryptoKeyReader cryptoKeyReader
```

cryptoFailureAction

ConsumerCryptoFailureAction cryptoFailureAction

readCompacted
```
boolean readCompacted
```
resetIncludeHead
```
boolean resetIncludeHead
```

Serialized Form

Package org.apache.pulsar.client.impl

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

Serialized Fields

batchIndex

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

numBatchReceiveFailed

numAcksSent

numAcksFailed

totalMsgsReceived

totalBytesReceived

totalReceiveFailed

totalBatchReceiveFailed

totalAcksSent

totalAcksFailed

receivedMsgsRate

receivedBytesRate

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

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

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.MultiMessageIdImpl extends Object implements Serializable

Serialized Fields

map

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

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

Serialized Fields

stat

statTimeout

producer

pulsarClient

oldTime

statsIntervalSeconds

numMsgsSent

numBytesSent

numSendFailed

numAcksReceived

totalMsgsSent

totalBytesSent

totalSendFailed

totalAcksReceived

ds

sendMsgsRate

sendBytesRate

latencyPctValues

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

Serialized Fields

partitionIndex

startPtnIdx

isBatchingEnabled

partitionSwitchMs

clock

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

Serialized Fields

partitionIndex

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

Serialized Fields

topicPartitionName

topicName

messageId

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

Serialized Fields

producer