Serialized Form (Pulsar Common 2.2.0 API)

Package org.apache.pulsar.common.api.proto
- Class org.apache.pulsar.common.api.proto.PulsarApi.BaseCommand extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - bitField1_
```
int bitField1_
```
    - type_
```
PulsarApi.BaseCommand.Type type_
```
    - connect_
```
PulsarApi.CommandConnect connect_
```
    - connected_
```
PulsarApi.CommandConnected connected_
```
    - subscribe_
```
PulsarApi.CommandSubscribe subscribe_
```
    - producer_
```
PulsarApi.CommandProducer producer_
```
    - send_
```
PulsarApi.CommandSend send_
```
    - sendReceipt_
```
PulsarApi.CommandSendReceipt sendReceipt_
```
    - sendError_
```
PulsarApi.CommandSendError sendError_
```
    - message_
```
PulsarApi.CommandMessage message_
```
    - ack_
```
PulsarApi.CommandAck ack_
```
    - flow_
```
PulsarApi.CommandFlow flow_
```
    - unsubscribe_
```
PulsarApi.CommandUnsubscribe unsubscribe_
```
    - success_
```
PulsarApi.CommandSuccess success_
```
    - error_
```
PulsarApi.CommandError error_
```
    - closeProducer_
```
PulsarApi.CommandCloseProducer closeProducer_
```
    - closeConsumer_
```
PulsarApi.CommandCloseConsumer closeConsumer_
```
    - producerSuccess_
```
PulsarApi.CommandProducerSuccess producerSuccess_
```
    - ping_
```
PulsarApi.CommandPing ping_
```
    - pong_
```
PulsarApi.CommandPong pong_
```
    - redeliverUnacknowledgedMessages_
```
PulsarApi.CommandRedeliverUnacknowledgedMessages redeliverUnacknowledgedMessages_
```
    - partitionMetadata_
```
PulsarApi.CommandPartitionedTopicMetadata partitionMetadata_
```
    - partitionMetadataResponse_
```
PulsarApi.CommandPartitionedTopicMetadataResponse partitionMetadataResponse_
```
    - lookupTopic_
```
PulsarApi.CommandLookupTopic lookupTopic_
```
    - lookupTopicResponse_
```
PulsarApi.CommandLookupTopicResponse lookupTopicResponse_
```
    - consumerStats_
```
PulsarApi.CommandConsumerStats consumerStats_
```
    - consumerStatsResponse_
```
PulsarApi.CommandConsumerStatsResponse consumerStatsResponse_
```
    - reachedEndOfTopic_
```
PulsarApi.CommandReachedEndOfTopic reachedEndOfTopic_
```
    - seek_
```
PulsarApi.CommandSeek seek_
```
    - getLastMessageId_
```
PulsarApi.CommandGetLastMessageId getLastMessageId_
```
    - getLastMessageIdResponse_
```
PulsarApi.CommandGetLastMessageIdResponse getLastMessageIdResponse_
```
    - activeConsumerChange_
```
PulsarApi.CommandActiveConsumerChange activeConsumerChange_
```
    - getTopicsOfNamespace_
```
PulsarApi.CommandGetTopicsOfNamespace getTopicsOfNamespace_
```
    - getTopicsOfNamespaceResponse_
```
PulsarApi.CommandGetTopicsOfNamespaceResponse getTopicsOfNamespaceResponse_
```
    - getSchema_
```
PulsarApi.CommandGetSchema getSchema_
```
    - getSchemaResponse_
```
PulsarApi.CommandGetSchemaResponse getSchemaResponse_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandAck extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - consumerId_
```
long consumerId_
```
    - ackType_
```
PulsarApi.CommandAck.AckType ackType_
```
    - messageId_
```
List<E> messageId_
```
    - validationError_
```
PulsarApi.CommandAck.ValidationError validationError_
```
    - properties_
```
List<E> properties_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandActiveConsumerChange extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - consumerId_
```
long consumerId_
```
    - isActive_
```
boolean isActive_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - consumerId_
```
long consumerId_
```
    - requestId_
```
long requestId_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseProducer extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - producerId_
```
long producerId_
```
    - requestId_
```
long requestId_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandConnect extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - clientVersion_
```
Object clientVersion_
```
    - authMethod_
```
PulsarApi.AuthMethod authMethod_
```
    - authMethodName_
```
Object authMethodName_
```
    - authData_
```
org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString authData_
```
    - protocolVersion_
```
int protocolVersion_
```
    - proxyToBrokerUrl_
```
Object proxyToBrokerUrl_
```
    - originalPrincipal_
```
Object originalPrincipal_
```
    - originalAuthData_
```
Object originalAuthData_
```
    - originalAuthMethod_
```
Object originalAuthMethod_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandConnected extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - serverVersion_
```
Object serverVersion_
```
    - protocolVersion_
```
int protocolVersion_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStats extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - requestId_
```
long requestId_
```
    - consumerId_
```
long consumerId_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStatsResponse extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - requestId_
```
long requestId_
```
    - errorCode_
```
PulsarApi.ServerError errorCode_
```
    - errorMessage_
```
Object errorMessage_
```
    - msgRateOut_
```
double msgRateOut_
```
    - msgThroughputOut_
```
double msgThroughputOut_
```
    - msgRateRedeliver_
```
double msgRateRedeliver_
```
    - consumerName_
```
Object consumerName_
```
    - availablePermits_
```
long availablePermits_
```
    - unackedMessages_
```
long unackedMessages_
```
    - blockedConsumerOnUnackedMsgs_
```
boolean blockedConsumerOnUnackedMsgs_
```
    - address_
```
Object address_
```
    - connectedSince_
```
Object connectedSince_
```
    - type_
```
Object type_
```
    - msgRateExpired_
```
double msgRateExpired_
```
    - msgBacklog_
```
long msgBacklog_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandError extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - requestId_
```
long requestId_
```
    - error_
```
PulsarApi.ServerError error_
```
    - message_
```
Object message_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandFlow extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - consumerId_
```
long consumerId_
```
    - messagePermits_
```
int messagePermits_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandGetLastMessageId extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - consumerId_
```
long consumerId_
```
    - requestId_
```
long requestId_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandGetLastMessageIdResponse extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - lastMessageId_
```
PulsarApi.MessageIdData lastMessageId_
```
    - requestId_
```
long requestId_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandGetSchema extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - requestId_
```
long requestId_
```
    - topic_
```
Object topic_
```
    - schemaVersion_
```
org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString schemaVersion_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandGetSchemaResponse extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - requestId_
```
long requestId_
```
    - errorCode_
```
PulsarApi.ServerError errorCode_
```
    - errorMessage_
```
Object errorMessage_
```
    - schema_
```
PulsarApi.Schema schema_
```
    - schemaVersion_
```
org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString schemaVersion_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandGetTopicsOfNamespace extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - requestId_
```
long requestId_
```
    - namespace_
```
Object namespace_
```
    - mode_
```
PulsarApi.CommandGetTopicsOfNamespace.Mode mode_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandGetTopicsOfNamespaceResponse extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - requestId_
```
long requestId_
```
    - topics_
```
org.apache.pulsar.shaded.com.google.protobuf.v241.LazyStringList topics_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopic extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - topic_
```
Object topic_
```
    - requestId_
```
long requestId_
```
    - authoritative_
```
boolean authoritative_
```
    - originalPrincipal_
```
Object originalPrincipal_
```
    - originalAuthData_
```
Object originalAuthData_
```
    - originalAuthMethod_
```
Object originalAuthMethod_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - brokerServiceUrl_
```
Object brokerServiceUrl_
```
    - brokerServiceUrlTls_
```
Object brokerServiceUrlTls_
```
    - response_
```
PulsarApi.CommandLookupTopicResponse.LookupType response_
```
    - requestId_
```
long requestId_
```
    - authoritative_
```
boolean authoritative_
```
    - error_
```
PulsarApi.ServerError error_
```
    - message_
```
Object message_
```
    - proxyThroughServiceUrl_
```
boolean proxyThroughServiceUrl_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandMessage extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - consumerId_
```
long consumerId_
```
    - messageId_
```
PulsarApi.MessageIdData messageId_
```
    - redeliveryCount_
```
int redeliveryCount_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - topic_
```
Object topic_
```
    - requestId_
```
long requestId_
```
    - originalPrincipal_
```
Object originalPrincipal_
```
    - originalAuthData_
```
Object originalAuthData_
```
    - originalAuthMethod_
```
Object originalAuthMethod_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - partitions_
```
int partitions_
```
    - requestId_
```
long requestId_
```
    - response_
```
PulsarApi.CommandPartitionedTopicMetadataResponse.LookupType response_
```
    - error_
```
PulsarApi.ServerError error_
```
    - message_
```
Object message_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandPing extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandPong extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandProducer extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - topic_
```
Object topic_
```
    - producerId_
```
long producerId_
```
    - requestId_
```
long requestId_
```
    - producerName_
```
Object producerName_
```
    - encrypted_
```
boolean encrypted_
```
    - metadata_
```
List<E> metadata_
```
    - schema_
```
PulsarApi.Schema schema_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandProducerSuccess extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - requestId_
```
long requestId_
```
    - producerName_
```
Object producerName_
```
    - lastSequenceId_
```
long lastSequenceId_
```
    - schemaVersion_
```
org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString schemaVersion_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - consumerId_
```
long consumerId_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - consumerId_
```
long consumerId_
```
    - messageIds_
```
List<E> messageIds_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandSeek extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - consumerId_
```
long consumerId_
```
    - requestId_
```
long requestId_
```
    - messageId_
```
PulsarApi.MessageIdData messageId_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandSend extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - producerId_
```
long producerId_
```
    - sequenceId_
```
long sequenceId_
```
    - numMessages_
```
int numMessages_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandSendError extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - producerId_
```
long producerId_
```
    - sequenceId_
```
long sequenceId_
```
    - error_
```
PulsarApi.ServerError error_
```
    - message_
```
Object message_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandSendReceipt extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - producerId_
```
long producerId_
```
    - sequenceId_
```
long sequenceId_
```
    - messageId_
```
PulsarApi.MessageIdData messageId_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandSubscribe extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - topic_
```
Object topic_
```
    - subscription_
```
Object subscription_
```
    - subType_
```
PulsarApi.CommandSubscribe.SubType subType_
```
    - consumerId_
```
long consumerId_
```
    - requestId_
```
long requestId_
```
    - consumerName_
```
Object consumerName_
```
    - priorityLevel_
```
int priorityLevel_
```
    - durable_
```
boolean durable_
```
    - startMessageId_
```
PulsarApi.MessageIdData startMessageId_
```
    - metadata_
```
List<E> metadata_
```
    - readCompacted_
```
boolean readCompacted_
```
    - schema_
```
PulsarApi.Schema schema_
```
    - initialPosition_
```
PulsarApi.CommandSubscribe.InitialPosition initialPosition_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandSuccess extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - requestId_
```
long requestId_
```
    - schema_
```
PulsarApi.Schema schema_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - consumerId_
```
long consumerId_
```
    - requestId_
```
long requestId_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.EncryptionKeys extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - key_
```
Object key_
```
    - value_
```
org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString value_
```
    - metadata_
```
List<E> metadata_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.KeyLongValue extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - key_
```
Object key_
```
    - value_
```
long value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.KeyValue extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - key_
```
Object key_
```
    - value_
```
Object value_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - ledgerId_
```
long ledgerId_
```
    - entryId_
```
long entryId_
```
    - partition_
```
int partition_
```
    - batchIndex_
```
int batchIndex_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - producerName_
```
Object producerName_
```
    - sequenceId_
```
long sequenceId_
```
    - publishTime_
```
long publishTime_
```
    - properties_
```
List<E> properties_
```
    - replicatedFrom_
```
Object replicatedFrom_
```
    - partitionKey_
```
Object partitionKey_
```
    - replicateTo_
```
org.apache.pulsar.shaded.com.google.protobuf.v241.LazyStringList replicateTo_
```
    - compression_
```
PulsarApi.CompressionType compression_
```
    - uncompressedSize_
```
int uncompressedSize_
```
    - numMessagesInBatch_
```
int numMessagesInBatch_
```
    - eventTime_
```
long eventTime_
```
    - encryptionKeys_
```
List<E> encryptionKeys_
```
    - encryptionAlgo_
```
Object encryptionAlgo_
```
    - encryptionParam_
```
org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString encryptionParam_
```
    - schemaVersion_
```
org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString schemaVersion_
```
    - partitionKeyB64Encoded_
```
boolean partitionKeyB64Encoded_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.Schema extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - name_
```
Object name_
```
    - schemaData_
```
org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString schemaData_
```
    - type_
```
PulsarApi.Schema.Type type_
```
    - properties_
```
List<E> properties_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
- Class org.apache.pulsar.common.api.proto.PulsarApi.SingleMessageMetadata extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialization Methods
    - writeReplace
```
protected Object writeReplace()
                       throws ObjectStreamException
```
      Throws:
      
      ObjectStreamException
  - Serialized Fields
    - handle
```
io.netty.util.Recycler.Handle<T> handle
```
    - bitField0_
```
int bitField0_
```
    - properties_
```
List<E> properties_
```
    - partitionKey_
```
Object partitionKey_
```
    - payloadSize_
```
int payloadSize_
```
    - compactedOut_
```
boolean compactedOut_
```
    - eventTime_
```
long eventTime_
```
    - partitionKeyB64Encoded_
```
boolean partitionKeyB64Encoded_
```
    - memoizedIsInitialized
```
byte memoizedIsInitialized
```
    - memoizedSerializedSize
```
int memoizedSerializedSize
```
Package org.apache.pulsar.common.policies.data
- Class org.apache.pulsar.common.policies.data.BookiesRackConfiguration extends TreeMap<String,Map<String,BookieInfo>> implements Serializable

Serialized Form

Package org.apache.pulsar.common.api.proto

Class org.apache.pulsar.common.api.proto.PulsarApi.BaseCommand extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable

Serialization Methods

writeReplace

Serialized Fields

handle

bitField0_

bitField1_

type_

connect_

connected_

subscribe_

producer_

send_

sendReceipt_

sendError_

message_

ack_

flow_

unsubscribe_

success_

error_

closeProducer_

closeConsumer_

producerSuccess_

ping_

pong_

redeliverUnacknowledgedMessages_

partitionMetadata_

partitionMetadataResponse_

lookupTopic_

lookupTopicResponse_

consumerStats_

consumerStatsResponse_

reachedEndOfTopic_

seek_

getLastMessageId_

getLastMessageIdResponse_

activeConsumerChange_

getTopicsOfNamespace_

getTopicsOfNamespaceResponse_

getSchema_

getSchemaResponse_

memoizedIsInitialized

memoizedSerializedSize

Class org.apache.pulsar.common.api.proto.PulsarApi.CommandAck extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable

Serialization Methods

writeReplace

Serialized Fields

handle

bitField0_

consumerId_

ackType_

messageId_

validationError_

properties_

memoizedIsInitialized

memoizedSerializedSize

Class org.apache.pulsar.common.api.proto.PulsarApi.CommandActiveConsumerChange extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable

Serialization Methods

writeReplace

Serialized Fields

handle

bitField0_

consumerId_

isActive_

memoizedIsInitialized

memoizedSerializedSize

Class org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable

Serialization Methods

writeReplace

Serialized Fields

handle

bitField0_

consumerId_

requestId_

memoizedIsInitialized

memoizedSerializedSize

Class org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseProducer extends org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite implements Serializable