// Generated by the protocol buffer compiler.  DO NOT EDIT!
// source: src/main/proto/PulsarMarkers.proto

package org.apache.pulsar.common.api.proto;

public final class PulsarMarkers {
  private PulsarMarkers() {}
  public static void registerAllExtensions(
      org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite registry) {
  }
  public enum MarkerType
      implements org.apache.pulsar.shaded.com.google.protobuf.v241.Internal.EnumLite {
    UNKNOWN_MARKER(0, 0),
    REPLICATED_SUBSCRIPTION_SNAPSHOT_REQUEST(1, 10),
    REPLICATED_SUBSCRIPTION_SNAPSHOT_RESPONSE(2, 11),
    REPLICATED_SUBSCRIPTION_SNAPSHOT(3, 12),
    REPLICATED_SUBSCRIPTION_UPDATE(4, 13),
    TXN_COMMIT(5, 20),
    TXN_ABORT(6, 21),
    ;
    
    public static final int UNKNOWN_MARKER_VALUE = 0;
    public static final int REPLICATED_SUBSCRIPTION_SNAPSHOT_REQUEST_VALUE = 10;
    public static final int REPLICATED_SUBSCRIPTION_SNAPSHOT_RESPONSE_VALUE = 11;
    public static final int REPLICATED_SUBSCRIPTION_SNAPSHOT_VALUE = 12;
    public static final int REPLICATED_SUBSCRIPTION_UPDATE_VALUE = 13;
    public static final int TXN_COMMIT_VALUE = 20;
    public static final int TXN_ABORT_VALUE = 21;
    
    
    public final int getNumber() { return value; }
    
    public static MarkerType valueOf(int value) {
      switch (value) {
        case 0: return UNKNOWN_MARKER;
        case 10: return REPLICATED_SUBSCRIPTION_SNAPSHOT_REQUEST;
        case 11: return REPLICATED_SUBSCRIPTION_SNAPSHOT_RESPONSE;
        case 12: return REPLICATED_SUBSCRIPTION_SNAPSHOT;
        case 13: return REPLICATED_SUBSCRIPTION_UPDATE;
        case 20: return TXN_COMMIT;
        case 21: return TXN_ABORT;
        default: return null;
      }
    }
    
    public static org.apache.pulsar.shaded.com.google.protobuf.v241.Internal.EnumLiteMap<MarkerType>
        internalGetValueMap() {
      return internalValueMap;
    }
    private static org.apache.pulsar.shaded.com.google.protobuf.v241.Internal.EnumLiteMap<MarkerType>
        internalValueMap =
          new org.apache.pulsar.shaded.com.google.protobuf.v241.Internal.EnumLiteMap<MarkerType>() {
            public MarkerType findValueByNumber(int number) {
              return MarkerType.valueOf(number);
            }
          };
    
    private final int value;
    
    private MarkerType(int index, int value) {
      this.value = value;
    }
    
    // @@protoc_insertion_point(enum_scope:pulsar.proto.MarkerType)
  }
  
  public interface ReplicatedSubscriptionsSnapshotRequestOrBuilder
      extends org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder {
    
    // required string snapshot_id = 1;
    boolean hasSnapshotId();
    String getSnapshotId();
    
    // optional string source_cluster = 2;
    boolean hasSourceCluster();
    String getSourceCluster();
  }
  public static final class ReplicatedSubscriptionsSnapshotRequest extends
      org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite
      implements ReplicatedSubscriptionsSnapshotRequestOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage  {
    // Use ReplicatedSubscriptionsSnapshotRequest.newBuilder() to construct.
    private io.netty.util.Recycler.Handle handle;
    private ReplicatedSubscriptionsSnapshotRequest(io.netty.util.Recycler.Handle handle) {
      this.handle = handle;
    }
    
     private static final io.netty.util.Recycler<ReplicatedSubscriptionsSnapshotRequest> RECYCLER = new io.netty.util.Recycler<ReplicatedSubscriptionsSnapshotRequest>() {
            protected ReplicatedSubscriptionsSnapshotRequest newObject(Handle handle) {
              return new ReplicatedSubscriptionsSnapshotRequest(handle);
            }
          };
        
        public void recycle() {
            this.initFields();
            this.memoizedIsInitialized = -1;
            this.bitField0_ = 0;
            this.memoizedSerializedSize = -1;
            if (handle != null) { RECYCLER.recycle(this, handle); }
        }
         
    private ReplicatedSubscriptionsSnapshotRequest(boolean noInit) {}
    
    private static final ReplicatedSubscriptionsSnapshotRequest defaultInstance;
    public static ReplicatedSubscriptionsSnapshotRequest getDefaultInstance() {
      return defaultInstance;
    }
    
    public ReplicatedSubscriptionsSnapshotRequest getDefaultInstanceForType() {
      return defaultInstance;
    }
    
    private int bitField0_;
    // required string snapshot_id = 1;
    public static final int SNAPSHOT_ID_FIELD_NUMBER = 1;
    private java.lang.Object snapshotId_;
    public boolean hasSnapshotId() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    public String getSnapshotId() {
      java.lang.Object ref = snapshotId_;
      if (ref instanceof String) {
        return (String) ref;
      } else {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString bs = 
            (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
        String s = bs.toStringUtf8();
        if (org.apache.pulsar.shaded.com.google.protobuf.v241.Internal.isValidUtf8(bs)) {
          snapshotId_ = s;
        }
        return s;
      }
    }
    private org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString getSnapshotIdBytes() {
      java.lang.Object ref = snapshotId_;
      if (ref instanceof String) {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString b = 
            org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString.copyFromUtf8((String) ref);
        snapshotId_ = b;
        return b;
      } else {
        return (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
      }
    }
    
    // optional string source_cluster = 2;
    public static final int SOURCE_CLUSTER_FIELD_NUMBER = 2;
    private java.lang.Object sourceCluster_;
    public boolean hasSourceCluster() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    public String getSourceCluster() {
      java.lang.Object ref = sourceCluster_;
      if (ref instanceof String) {
        return (String) ref;
      } else {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString bs = 
            (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
        String s = bs.toStringUtf8();
        if (org.apache.pulsar.shaded.com.google.protobuf.v241.Internal.isValidUtf8(bs)) {
          sourceCluster_ = s;
        }
        return s;
      }
    }
    private org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString getSourceClusterBytes() {
      java.lang.Object ref = sourceCluster_;
      if (ref instanceof String) {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString b = 
            org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString.copyFromUtf8((String) ref);
        sourceCluster_ = b;
        return b;
      } else {
        return (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
      }
    }
    
    private void initFields() {
      snapshotId_ = "";
      sourceCluster_ = "";
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;
      
      if (!hasSnapshotId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      memoizedIsInitialized = 1;
      return true;
    }
    
    public void writeTo(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream output)
                        throws java.io.IOException {
        throw new RuntimeException("Cannot use CodedOutputStream");
    }
    
    public void writeTo(org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream output)
                        throws java.io.IOException {
      getSerializedSize();
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        output.writeBytes(1, getSnapshotIdBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeBytes(2, getSourceClusterBytes());
      }
    }
    
    private int memoizedSerializedSize = -1;
    public int getSerializedSize() {
      int size = memoizedSerializedSize;
      if (size != -1) return size;
    
      size = 0;
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeBytesSize(1, getSnapshotIdBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeBytesSize(2, getSourceClusterBytes());
      }
      memoizedSerializedSize = size;
      return size;
    }
    
    private static final long serialVersionUID = 0L;
    @java.lang.Override
    protected java.lang.Object writeReplace()
        throws java.io.ObjectStreamException {
      return super.writeReplace();
    }
    
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest parseFrom(byte[] data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest parseFrom(
        byte[] data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest parseFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest parseDelimitedFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    
    public static Builder newBuilder() { return Builder.create(); }
    public Builder newBuilderForType() { return newBuilder(); }
    public static Builder newBuilder(org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest prototype) {
      return newBuilder().mergeFrom(prototype);
    }
    public Builder toBuilder() { return newBuilder(this); }
    
    public static final class Builder extends
        org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite.Builder<
          org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest, Builder>
        implements org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequestOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder  {
      // Construct using org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest.newBuilder()
      private final io.netty.util.Recycler.Handle handle;
      private Builder(io.netty.util.Recycler.Handle handle) {
        this.handle = handle;
        maybeForceBuilderInitialization();
      }
      private final static io.netty.util.Recycler<Builder> RECYCLER = new io.netty.util.Recycler<Builder>() {
         protected Builder newObject(io.netty.util.Recycler.Handle handle) {
               return new Builder(handle);
             }
            };
      
       public void recycle() {
                clear();
                if (handle != null) {RECYCLER.recycle(this, handle);}
            }
      
      private void maybeForceBuilderInitialization() {
      }
      private static Builder create() {
        return RECYCLER.get();
      }
      
      public Builder clear() {
        super.clear();
        snapshotId_ = "";
        bitField0_ = (bitField0_ & ~0x00000001);
        sourceCluster_ = "";
        bitField0_ = (bitField0_ & ~0x00000002);
        return this;
      }
      
      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest getDefaultInstanceForType() {
        return org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest.getDefaultInstance();
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest build() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }
      
      private org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest buildParsed()
          throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(
            result).asInvalidProtocolBufferException();
        }
        return result;
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest buildPartial() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest result = org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest.RECYCLER.get();
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.snapshotId_ = snapshotId_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.sourceCluster_ = sourceCluster_;
        result.bitField0_ = to_bitField0_;
        return result;
      }
      
      public Builder mergeFrom(org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest other) {
        if (other == org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotRequest.getDefaultInstance()) return this;
        if (other.hasSnapshotId()) {
          setSnapshotId(other.getSnapshotId());
        }
        if (other.hasSourceCluster()) {
          setSourceCluster(other.getSourceCluster());
        }
        return this;
      }
      
      public final boolean isInitialized() {
        if (!hasSnapshotId()) {
          
          return false;
        }
        return true;
      }
      
      public Builder mergeFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
                              org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
                              throws java.io.IOException {
         throw new java.io.IOException("Merge from CodedInputStream is disabled");
                              }
      public Builder mergeFrom(
          org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream input,
          org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        while (true) {
          int tag = input.readTag();
          switch (tag) {
            case 0:
              
              return this;
            default: {
              if (!input.skipField(tag)) {
                
                return this;
              }
              break;
            }
            case 10: {
              bitField0_ |= 0x00000001;
              snapshotId_ = input.readBytes();
              break;
            }
            case 18: {
              bitField0_ |= 0x00000002;
              sourceCluster_ = input.readBytes();
              break;
            }
          }
        }
      }
      
      private int bitField0_;
      
      // required string snapshot_id = 1;
      private java.lang.Object snapshotId_ = "";
      public boolean hasSnapshotId() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      public String getSnapshotId() {
        java.lang.Object ref = snapshotId_;
        if (!(ref instanceof String)) {
          String s = ((org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref).toStringUtf8();
          snapshotId_ = s;
          return s;
        } else {
          return (String) ref;
        }
      }
      public Builder setSnapshotId(String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        snapshotId_ = value;
        
        return this;
      }
      public Builder clearSnapshotId() {
        bitField0_ = (bitField0_ & ~0x00000001);
        snapshotId_ = getDefaultInstance().getSnapshotId();
        
        return this;
      }
      void setSnapshotId(org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString value) {
        bitField0_ |= 0x00000001;
        snapshotId_ = value;
        
      }
      
      // optional string source_cluster = 2;
      private java.lang.Object sourceCluster_ = "";
      public boolean hasSourceCluster() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      public String getSourceCluster() {
        java.lang.Object ref = sourceCluster_;
        if (!(ref instanceof String)) {
          String s = ((org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref).toStringUtf8();
          sourceCluster_ = s;
          return s;
        } else {
          return (String) ref;
        }
      }
      public Builder setSourceCluster(String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000002;
        sourceCluster_ = value;
        
        return this;
      }
      public Builder clearSourceCluster() {
        bitField0_ = (bitField0_ & ~0x00000002);
        sourceCluster_ = getDefaultInstance().getSourceCluster();
        
        return this;
      }
      void setSourceCluster(org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString value) {
        bitField0_ |= 0x00000002;
        sourceCluster_ = value;
        
      }
      
      // @@protoc_insertion_point(builder_scope:pulsar.proto.ReplicatedSubscriptionsSnapshotRequest)
    }
    
    static {
      defaultInstance = new ReplicatedSubscriptionsSnapshotRequest(true);
      defaultInstance.initFields();
    }
    
    // @@protoc_insertion_point(class_scope:pulsar.proto.ReplicatedSubscriptionsSnapshotRequest)
  }
  
  public interface ReplicatedSubscriptionsSnapshotResponseOrBuilder
      extends org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder {
    
    // required string snapshot_id = 1;
    boolean hasSnapshotId();
    String getSnapshotId();
    
    // optional .pulsar.proto.ClusterMessageId cluster = 2;
    boolean hasCluster();
    org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId getCluster();
  }
  public static final class ReplicatedSubscriptionsSnapshotResponse extends
      org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite
      implements ReplicatedSubscriptionsSnapshotResponseOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage  {
    // Use ReplicatedSubscriptionsSnapshotResponse.newBuilder() to construct.
    private io.netty.util.Recycler.Handle handle;
    private ReplicatedSubscriptionsSnapshotResponse(io.netty.util.Recycler.Handle handle) {
      this.handle = handle;
    }
    
     private static final io.netty.util.Recycler<ReplicatedSubscriptionsSnapshotResponse> RECYCLER = new io.netty.util.Recycler<ReplicatedSubscriptionsSnapshotResponse>() {
            protected ReplicatedSubscriptionsSnapshotResponse newObject(Handle handle) {
              return new ReplicatedSubscriptionsSnapshotResponse(handle);
            }
          };
        
        public void recycle() {
            this.initFields();
            this.memoizedIsInitialized = -1;
            this.bitField0_ = 0;
            this.memoizedSerializedSize = -1;
            if (handle != null) { RECYCLER.recycle(this, handle); }
        }
         
    private ReplicatedSubscriptionsSnapshotResponse(boolean noInit) {}
    
    private static final ReplicatedSubscriptionsSnapshotResponse defaultInstance;
    public static ReplicatedSubscriptionsSnapshotResponse getDefaultInstance() {
      return defaultInstance;
    }
    
    public ReplicatedSubscriptionsSnapshotResponse getDefaultInstanceForType() {
      return defaultInstance;
    }
    
    private int bitField0_;
    // required string snapshot_id = 1;
    public static final int SNAPSHOT_ID_FIELD_NUMBER = 1;
    private java.lang.Object snapshotId_;
    public boolean hasSnapshotId() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    public String getSnapshotId() {
      java.lang.Object ref = snapshotId_;
      if (ref instanceof String) {
        return (String) ref;
      } else {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString bs = 
            (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
        String s = bs.toStringUtf8();
        if (org.apache.pulsar.shaded.com.google.protobuf.v241.Internal.isValidUtf8(bs)) {
          snapshotId_ = s;
        }
        return s;
      }
    }
    private org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString getSnapshotIdBytes() {
      java.lang.Object ref = snapshotId_;
      if (ref instanceof String) {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString b = 
            org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString.copyFromUtf8((String) ref);
        snapshotId_ = b;
        return b;
      } else {
        return (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
      }
    }
    
    // optional .pulsar.proto.ClusterMessageId cluster = 2;
    public static final int CLUSTER_FIELD_NUMBER = 2;
    private org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId cluster_;
    public boolean hasCluster() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId getCluster() {
      return cluster_;
    }
    
    private void initFields() {
      snapshotId_ = "";
      cluster_ = org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.getDefaultInstance();
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;
      
      if (!hasSnapshotId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (hasCluster()) {
        if (!getCluster().isInitialized()) {
          memoizedIsInitialized = 0;
          return false;
        }
      }
      memoizedIsInitialized = 1;
      return true;
    }
    
    public void writeTo(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream output)
                        throws java.io.IOException {
        throw new RuntimeException("Cannot use CodedOutputStream");
    }
    
    public void writeTo(org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream output)
                        throws java.io.IOException {
      getSerializedSize();
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        output.writeBytes(1, getSnapshotIdBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeMessage(2, cluster_);
      }
    }
    
    private int memoizedSerializedSize = -1;
    public int getSerializedSize() {
      int size = memoizedSerializedSize;
      if (size != -1) return size;
    
      size = 0;
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeBytesSize(1, getSnapshotIdBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeMessageSize(2, cluster_);
      }
      memoizedSerializedSize = size;
      return size;
    }
    
    private static final long serialVersionUID = 0L;
    @java.lang.Override
    protected java.lang.Object writeReplace()
        throws java.io.ObjectStreamException {
      return super.writeReplace();
    }
    
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse parseFrom(byte[] data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse parseFrom(
        byte[] data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse parseFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse parseDelimitedFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    
    public static Builder newBuilder() { return Builder.create(); }
    public Builder newBuilderForType() { return newBuilder(); }
    public static Builder newBuilder(org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse prototype) {
      return newBuilder().mergeFrom(prototype);
    }
    public Builder toBuilder() { return newBuilder(this); }
    
    public static final class Builder extends
        org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite.Builder<
          org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse, Builder>
        implements org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponseOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder  {
      // Construct using org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse.newBuilder()
      private final io.netty.util.Recycler.Handle handle;
      private Builder(io.netty.util.Recycler.Handle handle) {
        this.handle = handle;
        maybeForceBuilderInitialization();
      }
      private final static io.netty.util.Recycler<Builder> RECYCLER = new io.netty.util.Recycler<Builder>() {
         protected Builder newObject(io.netty.util.Recycler.Handle handle) {
               return new Builder(handle);
             }
            };
      
       public void recycle() {
                clear();
                if (handle != null) {RECYCLER.recycle(this, handle);}
            }
      
      private void maybeForceBuilderInitialization() {
      }
      private static Builder create() {
        return RECYCLER.get();
      }
      
      public Builder clear() {
        super.clear();
        snapshotId_ = "";
        bitField0_ = (bitField0_ & ~0x00000001);
        cluster_ = org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.getDefaultInstance();
        bitField0_ = (bitField0_ & ~0x00000002);
        return this;
      }
      
      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse getDefaultInstanceForType() {
        return org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse.getDefaultInstance();
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse build() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }
      
      private org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse buildParsed()
          throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(
            result).asInvalidProtocolBufferException();
        }
        return result;
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse buildPartial() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse result = org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse.RECYCLER.get();
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.snapshotId_ = snapshotId_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.cluster_ = cluster_;
        result.bitField0_ = to_bitField0_;
        return result;
      }
      
      public Builder mergeFrom(org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse other) {
        if (other == org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotResponse.getDefaultInstance()) return this;
        if (other.hasSnapshotId()) {
          setSnapshotId(other.getSnapshotId());
        }
        if (other.hasCluster()) {
          mergeCluster(other.getCluster());
        }
        return this;
      }
      
      public final boolean isInitialized() {
        if (!hasSnapshotId()) {
          
          return false;
        }
        if (hasCluster()) {
          if (!getCluster().isInitialized()) {
            
            return false;
          }
        }
        return true;
      }
      
      public Builder mergeFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
                              org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
                              throws java.io.IOException {
         throw new java.io.IOException("Merge from CodedInputStream is disabled");
                              }
      public Builder mergeFrom(
          org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream input,
          org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        while (true) {
          int tag = input.readTag();
          switch (tag) {
            case 0:
              
              return this;
            default: {
              if (!input.skipField(tag)) {
                
                return this;
              }
              break;
            }
            case 10: {
              bitField0_ |= 0x00000001;
              snapshotId_ = input.readBytes();
              break;
            }
            case 18: {
              org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.Builder subBuilder = org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.newBuilder();
              if (hasCluster()) {
                subBuilder.mergeFrom(getCluster());
              }
              input.readMessage(subBuilder, extensionRegistry);
              setCluster(subBuilder.buildPartial());
              subBuilder.recycle();
              break;
            }
          }
        }
      }
      
      private int bitField0_;
      
      // required string snapshot_id = 1;
      private java.lang.Object snapshotId_ = "";
      public boolean hasSnapshotId() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      public String getSnapshotId() {
        java.lang.Object ref = snapshotId_;
        if (!(ref instanceof String)) {
          String s = ((org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref).toStringUtf8();
          snapshotId_ = s;
          return s;
        } else {
          return (String) ref;
        }
      }
      public Builder setSnapshotId(String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        snapshotId_ = value;
        
        return this;
      }
      public Builder clearSnapshotId() {
        bitField0_ = (bitField0_ & ~0x00000001);
        snapshotId_ = getDefaultInstance().getSnapshotId();
        
        return this;
      }
      void setSnapshotId(org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString value) {
        bitField0_ |= 0x00000001;
        snapshotId_ = value;
        
      }
      
      // optional .pulsar.proto.ClusterMessageId cluster = 2;
      private org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId cluster_ = org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.getDefaultInstance();
      public boolean hasCluster() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId getCluster() {
        return cluster_;
      }
      public Builder setCluster(org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId value) {
        if (value == null) {
          throw new NullPointerException();
        }
        cluster_ = value;
        
        bitField0_ |= 0x00000002;
        return this;
      }
      public Builder setCluster(
          org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.Builder builderForValue) {
        cluster_ = builderForValue.build();
        
        bitField0_ |= 0x00000002;
        return this;
      }
      public Builder mergeCluster(org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId value) {
        if (((bitField0_ & 0x00000002) == 0x00000002) &&
            cluster_ != org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.getDefaultInstance()) {
          cluster_ =
            org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.newBuilder(cluster_).mergeFrom(value).buildPartial();
        } else {
          cluster_ = value;
        }
        
        bitField0_ |= 0x00000002;
        return this;
      }
      public Builder clearCluster() {
        cluster_ = org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.getDefaultInstance();
        
        bitField0_ = (bitField0_ & ~0x00000002);
        return this;
      }
      
      // @@protoc_insertion_point(builder_scope:pulsar.proto.ReplicatedSubscriptionsSnapshotResponse)
    }
    
    static {
      defaultInstance = new ReplicatedSubscriptionsSnapshotResponse(true);
      defaultInstance.initFields();
    }
    
    // @@protoc_insertion_point(class_scope:pulsar.proto.ReplicatedSubscriptionsSnapshotResponse)
  }
  
  public interface ReplicatedSubscriptionsSnapshotOrBuilder
      extends org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder {
    
    // required string snapshot_id = 1;
    boolean hasSnapshotId();
    String getSnapshotId();
    
    // optional .pulsar.proto.MessageIdData local_message_id = 2;
    boolean hasLocalMessageId();
    org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData getLocalMessageId();
    
    // repeated .pulsar.proto.ClusterMessageId clusters = 3;
    java.util.List<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> 
        getClustersList();
    org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId getClusters(int index);
    int getClustersCount();
  }
  public static final class ReplicatedSubscriptionsSnapshot extends
      org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite
      implements ReplicatedSubscriptionsSnapshotOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage  {
    // Use ReplicatedSubscriptionsSnapshot.newBuilder() to construct.
    private io.netty.util.Recycler.Handle handle;
    private ReplicatedSubscriptionsSnapshot(io.netty.util.Recycler.Handle handle) {
      this.handle = handle;
    }
    
     private static final io.netty.util.Recycler<ReplicatedSubscriptionsSnapshot> RECYCLER = new io.netty.util.Recycler<ReplicatedSubscriptionsSnapshot>() {
            protected ReplicatedSubscriptionsSnapshot newObject(Handle handle) {
              return new ReplicatedSubscriptionsSnapshot(handle);
            }
          };
        
        public void recycle() {
            this.initFields();
            this.memoizedIsInitialized = -1;
            this.bitField0_ = 0;
            this.memoizedSerializedSize = -1;
            if (handle != null) { RECYCLER.recycle(this, handle); }
        }
         
    private ReplicatedSubscriptionsSnapshot(boolean noInit) {}
    
    private static final ReplicatedSubscriptionsSnapshot defaultInstance;
    public static ReplicatedSubscriptionsSnapshot getDefaultInstance() {
      return defaultInstance;
    }
    
    public ReplicatedSubscriptionsSnapshot getDefaultInstanceForType() {
      return defaultInstance;
    }
    
    private int bitField0_;
    // required string snapshot_id = 1;
    public static final int SNAPSHOT_ID_FIELD_NUMBER = 1;
    private java.lang.Object snapshotId_;
    public boolean hasSnapshotId() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    public String getSnapshotId() {
      java.lang.Object ref = snapshotId_;
      if (ref instanceof String) {
        return (String) ref;
      } else {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString bs = 
            (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
        String s = bs.toStringUtf8();
        if (org.apache.pulsar.shaded.com.google.protobuf.v241.Internal.isValidUtf8(bs)) {
          snapshotId_ = s;
        }
        return s;
      }
    }
    private org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString getSnapshotIdBytes() {
      java.lang.Object ref = snapshotId_;
      if (ref instanceof String) {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString b = 
            org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString.copyFromUtf8((String) ref);
        snapshotId_ = b;
        return b;
      } else {
        return (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
      }
    }
    
    // optional .pulsar.proto.MessageIdData local_message_id = 2;
    public static final int LOCAL_MESSAGE_ID_FIELD_NUMBER = 2;
    private org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData localMessageId_;
    public boolean hasLocalMessageId() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    public org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData getLocalMessageId() {
      return localMessageId_;
    }
    
    // repeated .pulsar.proto.ClusterMessageId clusters = 3;
    public static final int CLUSTERS_FIELD_NUMBER = 3;
    private java.util.List<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> clusters_;
    public java.util.List<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> getClustersList() {
      return clusters_;
    }
    public java.util.List<? extends org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageIdOrBuilder> 
        getClustersOrBuilderList() {
      return clusters_;
    }
    public int getClustersCount() {
      return clusters_.size();
    }
    public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId getClusters(int index) {
      return clusters_.get(index);
    }
    public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageIdOrBuilder getClustersOrBuilder(
        int index) {
      return clusters_.get(index);
    }
    
    private void initFields() {
      snapshotId_ = "";
      localMessageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
      clusters_ = java.util.Collections.emptyList();
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;
      
      if (!hasSnapshotId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (hasLocalMessageId()) {
        if (!getLocalMessageId().isInitialized()) {
          memoizedIsInitialized = 0;
          return false;
        }
      }
      for (int i = 0; i < getClustersCount(); i++) {
        if (!getClusters(i).isInitialized()) {
          memoizedIsInitialized = 0;
          return false;
        }
      }
      memoizedIsInitialized = 1;
      return true;
    }
    
    public void writeTo(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream output)
                        throws java.io.IOException {
        throw new RuntimeException("Cannot use CodedOutputStream");
    }
    
    public void writeTo(org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream output)
                        throws java.io.IOException {
      getSerializedSize();
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        output.writeBytes(1, getSnapshotIdBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeMessage(2, localMessageId_);
      }
      for (int i = 0; i < clusters_.size(); i++) {
        output.writeMessage(3, clusters_.get(i));
      }
    }
    
    private int memoizedSerializedSize = -1;
    public int getSerializedSize() {
      int size = memoizedSerializedSize;
      if (size != -1) return size;
    
      size = 0;
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeBytesSize(1, getSnapshotIdBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeMessageSize(2, localMessageId_);
      }
      for (int i = 0; i < clusters_.size(); i++) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeMessageSize(3, clusters_.get(i));
      }
      memoizedSerializedSize = size;
      return size;
    }
    
    private static final long serialVersionUID = 0L;
    @java.lang.Override
    protected java.lang.Object writeReplace()
        throws java.io.ObjectStreamException {
      return super.writeReplace();
    }
    
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot parseFrom(byte[] data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot parseFrom(
        byte[] data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot parseFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot parseDelimitedFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    
    public static Builder newBuilder() { return Builder.create(); }
    public Builder newBuilderForType() { return newBuilder(); }
    public static Builder newBuilder(org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot prototype) {
      return newBuilder().mergeFrom(prototype);
    }
    public Builder toBuilder() { return newBuilder(this); }
    
    public static final class Builder extends
        org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite.Builder<
          org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot, Builder>
        implements org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshotOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder  {
      // Construct using org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot.newBuilder()
      private final io.netty.util.Recycler.Handle handle;
      private Builder(io.netty.util.Recycler.Handle handle) {
        this.handle = handle;
        maybeForceBuilderInitialization();
      }
      private final static io.netty.util.Recycler<Builder> RECYCLER = new io.netty.util.Recycler<Builder>() {
         protected Builder newObject(io.netty.util.Recycler.Handle handle) {
               return new Builder(handle);
             }
            };
      
       public void recycle() {
                clear();
                if (handle != null) {RECYCLER.recycle(this, handle);}
            }
      
      private void maybeForceBuilderInitialization() {
      }
      private static Builder create() {
        return RECYCLER.get();
      }
      
      public Builder clear() {
        super.clear();
        snapshotId_ = "";
        bitField0_ = (bitField0_ & ~0x00000001);
        localMessageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
        bitField0_ = (bitField0_ & ~0x00000002);
        clusters_ = java.util.Collections.emptyList();
        bitField0_ = (bitField0_ & ~0x00000004);
        return this;
      }
      
      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot getDefaultInstanceForType() {
        return org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot.getDefaultInstance();
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot build() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }
      
      private org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot buildParsed()
          throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(
            result).asInvalidProtocolBufferException();
        }
        return result;
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot buildPartial() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot result = org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot.RECYCLER.get();
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.snapshotId_ = snapshotId_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.localMessageId_ = localMessageId_;
        if (((bitField0_ & 0x00000004) == 0x00000004)) {
          clusters_ = java.util.Collections.unmodifiableList(clusters_);
          bitField0_ = (bitField0_ & ~0x00000004);
        }
        result.clusters_ = clusters_;
        result.bitField0_ = to_bitField0_;
        return result;
      }
      
      public Builder mergeFrom(org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot other) {
        if (other == org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsSnapshot.getDefaultInstance()) return this;
        if (other.hasSnapshotId()) {
          setSnapshotId(other.getSnapshotId());
        }
        if (other.hasLocalMessageId()) {
          mergeLocalMessageId(other.getLocalMessageId());
        }
        if (!other.clusters_.isEmpty()) {
          if (clusters_.isEmpty()) {
            clusters_ = other.clusters_;
            bitField0_ = (bitField0_ & ~0x00000004);
          } else {
            ensureClustersIsMutable();
            clusters_.addAll(other.clusters_);
          }
          
        }
        return this;
      }
      
      public final boolean isInitialized() {
        if (!hasSnapshotId()) {
          
          return false;
        }
        if (hasLocalMessageId()) {
          if (!getLocalMessageId().isInitialized()) {
            
            return false;
          }
        }
        for (int i = 0; i < getClustersCount(); i++) {
          if (!getClusters(i).isInitialized()) {
            
            return false;
          }
        }
        return true;
      }
      
      public Builder mergeFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
                              org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
                              throws java.io.IOException {
         throw new java.io.IOException("Merge from CodedInputStream is disabled");
                              }
      public Builder mergeFrom(
          org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream input,
          org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        while (true) {
          int tag = input.readTag();
          switch (tag) {
            case 0:
              
              return this;
            default: {
              if (!input.skipField(tag)) {
                
                return this;
              }
              break;
            }
            case 10: {
              bitField0_ |= 0x00000001;
              snapshotId_ = input.readBytes();
              break;
            }
            case 18: {
              org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.Builder subBuilder = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.newBuilder();
              if (hasLocalMessageId()) {
                subBuilder.mergeFrom(getLocalMessageId());
              }
              input.readMessage(subBuilder, extensionRegistry);
              setLocalMessageId(subBuilder.buildPartial());
              subBuilder.recycle();
              break;
            }
            case 26: {
              org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.Builder subBuilder = org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.newBuilder();
              input.readMessage(subBuilder, extensionRegistry);
              addClusters(subBuilder.buildPartial());
              break;
            }
          }
        }
      }
      
      private int bitField0_;
      
      // required string snapshot_id = 1;
      private java.lang.Object snapshotId_ = "";
      public boolean hasSnapshotId() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      public String getSnapshotId() {
        java.lang.Object ref = snapshotId_;
        if (!(ref instanceof String)) {
          String s = ((org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref).toStringUtf8();
          snapshotId_ = s;
          return s;
        } else {
          return (String) ref;
        }
      }
      public Builder setSnapshotId(String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        snapshotId_ = value;
        
        return this;
      }
      public Builder clearSnapshotId() {
        bitField0_ = (bitField0_ & ~0x00000001);
        snapshotId_ = getDefaultInstance().getSnapshotId();
        
        return this;
      }
      void setSnapshotId(org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString value) {
        bitField0_ |= 0x00000001;
        snapshotId_ = value;
        
      }
      
      // optional .pulsar.proto.MessageIdData local_message_id = 2;
      private org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData localMessageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
      public boolean hasLocalMessageId() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      public org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData getLocalMessageId() {
        return localMessageId_;
      }
      public Builder setLocalMessageId(org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData value) {
        if (value == null) {
          throw new NullPointerException();
        }
        localMessageId_ = value;
        
        bitField0_ |= 0x00000002;
        return this;
      }
      public Builder setLocalMessageId(
          org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.Builder builderForValue) {
        localMessageId_ = builderForValue.build();
        
        bitField0_ |= 0x00000002;
        return this;
      }
      public Builder mergeLocalMessageId(org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData value) {
        if (((bitField0_ & 0x00000002) == 0x00000002) &&
            localMessageId_ != org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance()) {
          localMessageId_ =
            org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.newBuilder(localMessageId_).mergeFrom(value).buildPartial();
        } else {
          localMessageId_ = value;
        }
        
        bitField0_ |= 0x00000002;
        return this;
      }
      public Builder clearLocalMessageId() {
        localMessageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
        
        bitField0_ = (bitField0_ & ~0x00000002);
        return this;
      }
      
      // repeated .pulsar.proto.ClusterMessageId clusters = 3;
      private java.util.List<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> clusters_ =
        java.util.Collections.emptyList();
      private void ensureClustersIsMutable() {
        if (!((bitField0_ & 0x00000004) == 0x00000004)) {
          clusters_ = new java.util.ArrayList<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId>(clusters_);
          bitField0_ |= 0x00000004;
         }
      }
      
      public java.util.List<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> getClustersList() {
        return java.util.Collections.unmodifiableList(clusters_);
      }
      public int getClustersCount() {
        return clusters_.size();
      }
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId getClusters(int index) {
        return clusters_.get(index);
      }
      public Builder setClusters(
          int index, org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId value) {
        if (value == null) {
          throw new NullPointerException();
        }
        ensureClustersIsMutable();
        clusters_.set(index, value);
        
        return this;
      }
      public Builder setClusters(
          int index, org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.Builder builderForValue) {
        ensureClustersIsMutable();
        clusters_.set(index, builderForValue.build());
        
        return this;
      }
      public Builder addClusters(org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId value) {
        if (value == null) {
          throw new NullPointerException();
        }
        ensureClustersIsMutable();
        clusters_.add(value);
        
        return this;
      }
      public Builder addClusters(
          int index, org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId value) {
        if (value == null) {
          throw new NullPointerException();
        }
        ensureClustersIsMutable();
        clusters_.add(index, value);
        
        return this;
      }
      public Builder addClusters(
          org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.Builder builderForValue) {
        ensureClustersIsMutable();
        clusters_.add(builderForValue.build());
        
        return this;
      }
      public Builder addClusters(
          int index, org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.Builder builderForValue) {
        ensureClustersIsMutable();
        clusters_.add(index, builderForValue.build());
        
        return this;
      }
      public Builder addAllClusters(
          java.lang.Iterable<? extends org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> values) {
        ensureClustersIsMutable();
        super.addAll(values, clusters_);
        
        return this;
      }
      public Builder clearClusters() {
        clusters_ = java.util.Collections.emptyList();
        bitField0_ = (bitField0_ & ~0x00000004);
        
        return this;
      }
      public Builder removeClusters(int index) {
        ensureClustersIsMutable();
        clusters_.remove(index);
        
        return this;
      }
      
      // @@protoc_insertion_point(builder_scope:pulsar.proto.ReplicatedSubscriptionsSnapshot)
    }
    
    static {
      defaultInstance = new ReplicatedSubscriptionsSnapshot(true);
      defaultInstance.initFields();
    }
    
    // @@protoc_insertion_point(class_scope:pulsar.proto.ReplicatedSubscriptionsSnapshot)
  }
  
  public interface ReplicatedSubscriptionsUpdateOrBuilder
      extends org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder {
    
    // required string subscription_name = 1;
    boolean hasSubscriptionName();
    String getSubscriptionName();
    
    // repeated .pulsar.proto.ClusterMessageId clusters = 2;
    java.util.List<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> 
        getClustersList();
    org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId getClusters(int index);
    int getClustersCount();
  }
  public static final class ReplicatedSubscriptionsUpdate extends
      org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite
      implements ReplicatedSubscriptionsUpdateOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage  {
    // Use ReplicatedSubscriptionsUpdate.newBuilder() to construct.
    private io.netty.util.Recycler.Handle handle;
    private ReplicatedSubscriptionsUpdate(io.netty.util.Recycler.Handle handle) {
      this.handle = handle;
    }
    
     private static final io.netty.util.Recycler<ReplicatedSubscriptionsUpdate> RECYCLER = new io.netty.util.Recycler<ReplicatedSubscriptionsUpdate>() {
            protected ReplicatedSubscriptionsUpdate newObject(Handle handle) {
              return new ReplicatedSubscriptionsUpdate(handle);
            }
          };
        
        public void recycle() {
            this.initFields();
            this.memoizedIsInitialized = -1;
            this.bitField0_ = 0;
            this.memoizedSerializedSize = -1;
            if (handle != null) { RECYCLER.recycle(this, handle); }
        }
         
    private ReplicatedSubscriptionsUpdate(boolean noInit) {}
    
    private static final ReplicatedSubscriptionsUpdate defaultInstance;
    public static ReplicatedSubscriptionsUpdate getDefaultInstance() {
      return defaultInstance;
    }
    
    public ReplicatedSubscriptionsUpdate getDefaultInstanceForType() {
      return defaultInstance;
    }
    
    private int bitField0_;
    // required string subscription_name = 1;
    public static final int SUBSCRIPTION_NAME_FIELD_NUMBER = 1;
    private java.lang.Object subscriptionName_;
    public boolean hasSubscriptionName() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    public String getSubscriptionName() {
      java.lang.Object ref = subscriptionName_;
      if (ref instanceof String) {
        return (String) ref;
      } else {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString bs = 
            (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
        String s = bs.toStringUtf8();
        if (org.apache.pulsar.shaded.com.google.protobuf.v241.Internal.isValidUtf8(bs)) {
          subscriptionName_ = s;
        }
        return s;
      }
    }
    private org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString getSubscriptionNameBytes() {
      java.lang.Object ref = subscriptionName_;
      if (ref instanceof String) {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString b = 
            org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString.copyFromUtf8((String) ref);
        subscriptionName_ = b;
        return b;
      } else {
        return (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
      }
    }
    
    // repeated .pulsar.proto.ClusterMessageId clusters = 2;
    public static final int CLUSTERS_FIELD_NUMBER = 2;
    private java.util.List<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> clusters_;
    public java.util.List<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> getClustersList() {
      return clusters_;
    }
    public java.util.List<? extends org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageIdOrBuilder> 
        getClustersOrBuilderList() {
      return clusters_;
    }
    public int getClustersCount() {
      return clusters_.size();
    }
    public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId getClusters(int index) {
      return clusters_.get(index);
    }
    public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageIdOrBuilder getClustersOrBuilder(
        int index) {
      return clusters_.get(index);
    }
    
    private void initFields() {
      subscriptionName_ = "";
      clusters_ = java.util.Collections.emptyList();
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;
      
      if (!hasSubscriptionName()) {
        memoizedIsInitialized = 0;
        return false;
      }
      for (int i = 0; i < getClustersCount(); i++) {
        if (!getClusters(i).isInitialized()) {
          memoizedIsInitialized = 0;
          return false;
        }
      }
      memoizedIsInitialized = 1;
      return true;
    }
    
    public void writeTo(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream output)
                        throws java.io.IOException {
        throw new RuntimeException("Cannot use CodedOutputStream");
    }
    
    public void writeTo(org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream output)
                        throws java.io.IOException {
      getSerializedSize();
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        output.writeBytes(1, getSubscriptionNameBytes());
      }
      for (int i = 0; i < clusters_.size(); i++) {
        output.writeMessage(2, clusters_.get(i));
      }
    }
    
    private int memoizedSerializedSize = -1;
    public int getSerializedSize() {
      int size = memoizedSerializedSize;
      if (size != -1) return size;
    
      size = 0;
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeBytesSize(1, getSubscriptionNameBytes());
      }
      for (int i = 0; i < clusters_.size(); i++) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeMessageSize(2, clusters_.get(i));
      }
      memoizedSerializedSize = size;
      return size;
    }
    
    private static final long serialVersionUID = 0L;
    @java.lang.Override
    protected java.lang.Object writeReplace()
        throws java.io.ObjectStreamException {
      return super.writeReplace();
    }
    
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate parseFrom(byte[] data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate parseFrom(
        byte[] data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate parseFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate parseDelimitedFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    
    public static Builder newBuilder() { return Builder.create(); }
    public Builder newBuilderForType() { return newBuilder(); }
    public static Builder newBuilder(org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate prototype) {
      return newBuilder().mergeFrom(prototype);
    }
    public Builder toBuilder() { return newBuilder(this); }
    
    public static final class Builder extends
        org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite.Builder<
          org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate, Builder>
        implements org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdateOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder  {
      // Construct using org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate.newBuilder()
      private final io.netty.util.Recycler.Handle handle;
      private Builder(io.netty.util.Recycler.Handle handle) {
        this.handle = handle;
        maybeForceBuilderInitialization();
      }
      private final static io.netty.util.Recycler<Builder> RECYCLER = new io.netty.util.Recycler<Builder>() {
         protected Builder newObject(io.netty.util.Recycler.Handle handle) {
               return new Builder(handle);
             }
            };
      
       public void recycle() {
                clear();
                if (handle != null) {RECYCLER.recycle(this, handle);}
            }
      
      private void maybeForceBuilderInitialization() {
      }
      private static Builder create() {
        return RECYCLER.get();
      }
      
      public Builder clear() {
        super.clear();
        subscriptionName_ = "";
        bitField0_ = (bitField0_ & ~0x00000001);
        clusters_ = java.util.Collections.emptyList();
        bitField0_ = (bitField0_ & ~0x00000002);
        return this;
      }
      
      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate getDefaultInstanceForType() {
        return org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate.getDefaultInstance();
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate build() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }
      
      private org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate buildParsed()
          throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(
            result).asInvalidProtocolBufferException();
        }
        return result;
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate buildPartial() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate result = org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate.RECYCLER.get();
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.subscriptionName_ = subscriptionName_;
        if (((bitField0_ & 0x00000002) == 0x00000002)) {
          clusters_ = java.util.Collections.unmodifiableList(clusters_);
          bitField0_ = (bitField0_ & ~0x00000002);
        }
        result.clusters_ = clusters_;
        result.bitField0_ = to_bitField0_;
        return result;
      }
      
      public Builder mergeFrom(org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate other) {
        if (other == org.apache.pulsar.common.api.proto.PulsarMarkers.ReplicatedSubscriptionsUpdate.getDefaultInstance()) return this;
        if (other.hasSubscriptionName()) {
          setSubscriptionName(other.getSubscriptionName());
        }
        if (!other.clusters_.isEmpty()) {
          if (clusters_.isEmpty()) {
            clusters_ = other.clusters_;
            bitField0_ = (bitField0_ & ~0x00000002);
          } else {
            ensureClustersIsMutable();
            clusters_.addAll(other.clusters_);
          }
          
        }
        return this;
      }
      
      public final boolean isInitialized() {
        if (!hasSubscriptionName()) {
          
          return false;
        }
        for (int i = 0; i < getClustersCount(); i++) {
          if (!getClusters(i).isInitialized()) {
            
            return false;
          }
        }
        return true;
      }
      
      public Builder mergeFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
                              org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
                              throws java.io.IOException {
         throw new java.io.IOException("Merge from CodedInputStream is disabled");
                              }
      public Builder mergeFrom(
          org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream input,
          org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        while (true) {
          int tag = input.readTag();
          switch (tag) {
            case 0:
              
              return this;
            default: {
              if (!input.skipField(tag)) {
                
                return this;
              }
              break;
            }
            case 10: {
              bitField0_ |= 0x00000001;
              subscriptionName_ = input.readBytes();
              break;
            }
            case 18: {
              org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.Builder subBuilder = org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.newBuilder();
              input.readMessage(subBuilder, extensionRegistry);
              addClusters(subBuilder.buildPartial());
              break;
            }
          }
        }
      }
      
      private int bitField0_;
      
      // required string subscription_name = 1;
      private java.lang.Object subscriptionName_ = "";
      public boolean hasSubscriptionName() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      public String getSubscriptionName() {
        java.lang.Object ref = subscriptionName_;
        if (!(ref instanceof String)) {
          String s = ((org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref).toStringUtf8();
          subscriptionName_ = s;
          return s;
        } else {
          return (String) ref;
        }
      }
      public Builder setSubscriptionName(String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        subscriptionName_ = value;
        
        return this;
      }
      public Builder clearSubscriptionName() {
        bitField0_ = (bitField0_ & ~0x00000001);
        subscriptionName_ = getDefaultInstance().getSubscriptionName();
        
        return this;
      }
      void setSubscriptionName(org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString value) {
        bitField0_ |= 0x00000001;
        subscriptionName_ = value;
        
      }
      
      // repeated .pulsar.proto.ClusterMessageId clusters = 2;
      private java.util.List<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> clusters_ =
        java.util.Collections.emptyList();
      private void ensureClustersIsMutable() {
        if (!((bitField0_ & 0x00000002) == 0x00000002)) {
          clusters_ = new java.util.ArrayList<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId>(clusters_);
          bitField0_ |= 0x00000002;
         }
      }
      
      public java.util.List<org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> getClustersList() {
        return java.util.Collections.unmodifiableList(clusters_);
      }
      public int getClustersCount() {
        return clusters_.size();
      }
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId getClusters(int index) {
        return clusters_.get(index);
      }
      public Builder setClusters(
          int index, org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId value) {
        if (value == null) {
          throw new NullPointerException();
        }
        ensureClustersIsMutable();
        clusters_.set(index, value);
        
        return this;
      }
      public Builder setClusters(
          int index, org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.Builder builderForValue) {
        ensureClustersIsMutable();
        clusters_.set(index, builderForValue.build());
        
        return this;
      }
      public Builder addClusters(org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId value) {
        if (value == null) {
          throw new NullPointerException();
        }
        ensureClustersIsMutable();
        clusters_.add(value);
        
        return this;
      }
      public Builder addClusters(
          int index, org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId value) {
        if (value == null) {
          throw new NullPointerException();
        }
        ensureClustersIsMutable();
        clusters_.add(index, value);
        
        return this;
      }
      public Builder addClusters(
          org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.Builder builderForValue) {
        ensureClustersIsMutable();
        clusters_.add(builderForValue.build());
        
        return this;
      }
      public Builder addClusters(
          int index, org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.Builder builderForValue) {
        ensureClustersIsMutable();
        clusters_.add(index, builderForValue.build());
        
        return this;
      }
      public Builder addAllClusters(
          java.lang.Iterable<? extends org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId> values) {
        ensureClustersIsMutable();
        super.addAll(values, clusters_);
        
        return this;
      }
      public Builder clearClusters() {
        clusters_ = java.util.Collections.emptyList();
        bitField0_ = (bitField0_ & ~0x00000002);
        
        return this;
      }
      public Builder removeClusters(int index) {
        ensureClustersIsMutable();
        clusters_.remove(index);
        
        return this;
      }
      
      // @@protoc_insertion_point(builder_scope:pulsar.proto.ReplicatedSubscriptionsUpdate)
    }
    
    static {
      defaultInstance = new ReplicatedSubscriptionsUpdate(true);
      defaultInstance.initFields();
    }
    
    // @@protoc_insertion_point(class_scope:pulsar.proto.ReplicatedSubscriptionsUpdate)
  }
  
  public interface ClusterMessageIdOrBuilder
      extends org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder {
    
    // required string cluster = 1;
    boolean hasCluster();
    String getCluster();
    
    // required .pulsar.proto.MessageIdData message_id = 2;
    boolean hasMessageId();
    org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData getMessageId();
  }
  public static final class ClusterMessageId extends
      org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite
      implements ClusterMessageIdOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage  {
    // Use ClusterMessageId.newBuilder() to construct.
    private io.netty.util.Recycler.Handle handle;
    private ClusterMessageId(io.netty.util.Recycler.Handle handle) {
      this.handle = handle;
    }
    
     private static final io.netty.util.Recycler<ClusterMessageId> RECYCLER = new io.netty.util.Recycler<ClusterMessageId>() {
            protected ClusterMessageId newObject(Handle handle) {
              return new ClusterMessageId(handle);
            }
          };
        
        public void recycle() {
            this.initFields();
            this.memoizedIsInitialized = -1;
            this.bitField0_ = 0;
            this.memoizedSerializedSize = -1;
            if (handle != null) { RECYCLER.recycle(this, handle); }
        }
         
    private ClusterMessageId(boolean noInit) {}
    
    private static final ClusterMessageId defaultInstance;
    public static ClusterMessageId getDefaultInstance() {
      return defaultInstance;
    }
    
    public ClusterMessageId getDefaultInstanceForType() {
      return defaultInstance;
    }
    
    private int bitField0_;
    // required string cluster = 1;
    public static final int CLUSTER_FIELD_NUMBER = 1;
    private java.lang.Object cluster_;
    public boolean hasCluster() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    public String getCluster() {
      java.lang.Object ref = cluster_;
      if (ref instanceof String) {
        return (String) ref;
      } else {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString bs = 
            (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
        String s = bs.toStringUtf8();
        if (org.apache.pulsar.shaded.com.google.protobuf.v241.Internal.isValidUtf8(bs)) {
          cluster_ = s;
        }
        return s;
      }
    }
    private org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString getClusterBytes() {
      java.lang.Object ref = cluster_;
      if (ref instanceof String) {
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString b = 
            org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString.copyFromUtf8((String) ref);
        cluster_ = b;
        return b;
      } else {
        return (org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref;
      }
    }
    
    // required .pulsar.proto.MessageIdData message_id = 2;
    public static final int MESSAGE_ID_FIELD_NUMBER = 2;
    private org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData messageId_;
    public boolean hasMessageId() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    public org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData getMessageId() {
      return messageId_;
    }
    
    private void initFields() {
      cluster_ = "";
      messageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;
      
      if (!hasCluster()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!hasMessageId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!getMessageId().isInitialized()) {
        memoizedIsInitialized = 0;
        return false;
      }
      memoizedIsInitialized = 1;
      return true;
    }
    
    public void writeTo(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream output)
                        throws java.io.IOException {
        throw new RuntimeException("Cannot use CodedOutputStream");
    }
    
    public void writeTo(org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream output)
                        throws java.io.IOException {
      getSerializedSize();
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        output.writeBytes(1, getClusterBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeMessage(2, messageId_);
      }
    }
    
    private int memoizedSerializedSize = -1;
    public int getSerializedSize() {
      int size = memoizedSerializedSize;
      if (size != -1) return size;
    
      size = 0;
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeBytesSize(1, getClusterBytes());
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeMessageSize(2, messageId_);
      }
      memoizedSerializedSize = size;
      return size;
    }
    
    private static final long serialVersionUID = 0L;
    @java.lang.Override
    protected java.lang.Object writeReplace()
        throws java.io.ObjectStreamException {
      return super.writeReplace();
    }
    
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId parseFrom(byte[] data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId parseFrom(
        byte[] data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId parseFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId parseDelimitedFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    
    public static Builder newBuilder() { return Builder.create(); }
    public Builder newBuilderForType() { return newBuilder(); }
    public static Builder newBuilder(org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId prototype) {
      return newBuilder().mergeFrom(prototype);
    }
    public Builder toBuilder() { return newBuilder(this); }
    
    public static final class Builder extends
        org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite.Builder<
          org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId, Builder>
        implements org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageIdOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder  {
      // Construct using org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.newBuilder()
      private final io.netty.util.Recycler.Handle handle;
      private Builder(io.netty.util.Recycler.Handle handle) {
        this.handle = handle;
        maybeForceBuilderInitialization();
      }
      private final static io.netty.util.Recycler<Builder> RECYCLER = new io.netty.util.Recycler<Builder>() {
         protected Builder newObject(io.netty.util.Recycler.Handle handle) {
               return new Builder(handle);
             }
            };
      
       public void recycle() {
                clear();
                if (handle != null) {RECYCLER.recycle(this, handle);}
            }
      
      private void maybeForceBuilderInitialization() {
      }
      private static Builder create() {
        return RECYCLER.get();
      }
      
      public Builder clear() {
        super.clear();
        cluster_ = "";
        bitField0_ = (bitField0_ & ~0x00000001);
        messageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
        bitField0_ = (bitField0_ & ~0x00000002);
        return this;
      }
      
      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId getDefaultInstanceForType() {
        return org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.getDefaultInstance();
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId build() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }
      
      private org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId buildParsed()
          throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(
            result).asInvalidProtocolBufferException();
        }
        return result;
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId buildPartial() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId result = org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.RECYCLER.get();
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.cluster_ = cluster_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.messageId_ = messageId_;
        result.bitField0_ = to_bitField0_;
        return result;
      }
      
      public Builder mergeFrom(org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId other) {
        if (other == org.apache.pulsar.common.api.proto.PulsarMarkers.ClusterMessageId.getDefaultInstance()) return this;
        if (other.hasCluster()) {
          setCluster(other.getCluster());
        }
        if (other.hasMessageId()) {
          mergeMessageId(other.getMessageId());
        }
        return this;
      }
      
      public final boolean isInitialized() {
        if (!hasCluster()) {
          
          return false;
        }
        if (!hasMessageId()) {
          
          return false;
        }
        if (!getMessageId().isInitialized()) {
          
          return false;
        }
        return true;
      }
      
      public Builder mergeFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
                              org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
                              throws java.io.IOException {
         throw new java.io.IOException("Merge from CodedInputStream is disabled");
                              }
      public Builder mergeFrom(
          org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream input,
          org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        while (true) {
          int tag = input.readTag();
          switch (tag) {
            case 0:
              
              return this;
            default: {
              if (!input.skipField(tag)) {
                
                return this;
              }
              break;
            }
            case 10: {
              bitField0_ |= 0x00000001;
              cluster_ = input.readBytes();
              break;
            }
            case 18: {
              org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.Builder subBuilder = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.newBuilder();
              if (hasMessageId()) {
                subBuilder.mergeFrom(getMessageId());
              }
              input.readMessage(subBuilder, extensionRegistry);
              setMessageId(subBuilder.buildPartial());
              subBuilder.recycle();
              break;
            }
          }
        }
      }
      
      private int bitField0_;
      
      // required string cluster = 1;
      private java.lang.Object cluster_ = "";
      public boolean hasCluster() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      public String getCluster() {
        java.lang.Object ref = cluster_;
        if (!(ref instanceof String)) {
          String s = ((org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString) ref).toStringUtf8();
          cluster_ = s;
          return s;
        } else {
          return (String) ref;
        }
      }
      public Builder setCluster(String value) {
        if (value == null) {
    throw new NullPointerException();
  }
  bitField0_ |= 0x00000001;
        cluster_ = value;
        
        return this;
      }
      public Builder clearCluster() {
        bitField0_ = (bitField0_ & ~0x00000001);
        cluster_ = getDefaultInstance().getCluster();
        
        return this;
      }
      void setCluster(org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString value) {
        bitField0_ |= 0x00000001;
        cluster_ = value;
        
      }
      
      // required .pulsar.proto.MessageIdData message_id = 2;
      private org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData messageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
      public boolean hasMessageId() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      public org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData getMessageId() {
        return messageId_;
      }
      public Builder setMessageId(org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData value) {
        if (value == null) {
          throw new NullPointerException();
        }
        messageId_ = value;
        
        bitField0_ |= 0x00000002;
        return this;
      }
      public Builder setMessageId(
          org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.Builder builderForValue) {
        messageId_ = builderForValue.build();
        
        bitField0_ |= 0x00000002;
        return this;
      }
      public Builder mergeMessageId(org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData value) {
        if (((bitField0_ & 0x00000002) == 0x00000002) &&
            messageId_ != org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance()) {
          messageId_ =
            org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.newBuilder(messageId_).mergeFrom(value).buildPartial();
        } else {
          messageId_ = value;
        }
        
        bitField0_ |= 0x00000002;
        return this;
      }
      public Builder clearMessageId() {
        messageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
        
        bitField0_ = (bitField0_ & ~0x00000002);
        return this;
      }
      
      // @@protoc_insertion_point(builder_scope:pulsar.proto.ClusterMessageId)
    }
    
    static {
      defaultInstance = new ClusterMessageId(true);
      defaultInstance.initFields();
    }
    
    // @@protoc_insertion_point(class_scope:pulsar.proto.ClusterMessageId)
  }
  
  public interface MessageIdDataOrBuilder
      extends org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder {
    
    // required uint64 ledger_id = 1;
    boolean hasLedgerId();
    long getLedgerId();
    
    // required uint64 entry_id = 2;
    boolean hasEntryId();
    long getEntryId();
  }
  public static final class MessageIdData extends
      org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite
      implements MessageIdDataOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage  {
    // Use MessageIdData.newBuilder() to construct.
    private io.netty.util.Recycler.Handle handle;
    private MessageIdData(io.netty.util.Recycler.Handle handle) {
      this.handle = handle;
    }
    
     private static final io.netty.util.Recycler<MessageIdData> RECYCLER = new io.netty.util.Recycler<MessageIdData>() {
            protected MessageIdData newObject(Handle handle) {
              return new MessageIdData(handle);
            }
          };
        
        public void recycle() {
            this.initFields();
            this.memoizedIsInitialized = -1;
            this.bitField0_ = 0;
            this.memoizedSerializedSize = -1;
            if (handle != null) { RECYCLER.recycle(this, handle); }
        }
         
    private MessageIdData(boolean noInit) {}
    
    private static final MessageIdData defaultInstance;
    public static MessageIdData getDefaultInstance() {
      return defaultInstance;
    }
    
    public MessageIdData getDefaultInstanceForType() {
      return defaultInstance;
    }
    
    private int bitField0_;
    // required uint64 ledger_id = 1;
    public static final int LEDGER_ID_FIELD_NUMBER = 1;
    private long ledgerId_;
    public boolean hasLedgerId() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    public long getLedgerId() {
      return ledgerId_;
    }
    
    // required uint64 entry_id = 2;
    public static final int ENTRY_ID_FIELD_NUMBER = 2;
    private long entryId_;
    public boolean hasEntryId() {
      return ((bitField0_ & 0x00000002) == 0x00000002);
    }
    public long getEntryId() {
      return entryId_;
    }
    
    private void initFields() {
      ledgerId_ = 0L;
      entryId_ = 0L;
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;
      
      if (!hasLedgerId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!hasEntryId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      memoizedIsInitialized = 1;
      return true;
    }
    
    public void writeTo(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream output)
                        throws java.io.IOException {
        throw new RuntimeException("Cannot use CodedOutputStream");
    }
    
    public void writeTo(org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream output)
                        throws java.io.IOException {
      getSerializedSize();
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        output.writeUInt64(1, ledgerId_);
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        output.writeUInt64(2, entryId_);
      }
    }
    
    private int memoizedSerializedSize = -1;
    public int getSerializedSize() {
      int size = memoizedSerializedSize;
      if (size != -1) return size;
    
      size = 0;
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeUInt64Size(1, ledgerId_);
      }
      if (((bitField0_ & 0x00000002) == 0x00000002)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeUInt64Size(2, entryId_);
      }
      memoizedSerializedSize = size;
      return size;
    }
    
    private static final long serialVersionUID = 0L;
    @java.lang.Override
    protected java.lang.Object writeReplace()
        throws java.io.ObjectStreamException {
      return super.writeReplace();
    }
    
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData parseFrom(byte[] data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData parseFrom(
        byte[] data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData parseFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData parseDelimitedFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    
    public static Builder newBuilder() { return Builder.create(); }
    public Builder newBuilderForType() { return newBuilder(); }
    public static Builder newBuilder(org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData prototype) {
      return newBuilder().mergeFrom(prototype);
    }
    public Builder toBuilder() { return newBuilder(this); }
    
    public static final class Builder extends
        org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite.Builder<
          org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData, Builder>
        implements org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdDataOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder  {
      // Construct using org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.newBuilder()
      private final io.netty.util.Recycler.Handle handle;
      private Builder(io.netty.util.Recycler.Handle handle) {
        this.handle = handle;
        maybeForceBuilderInitialization();
      }
      private final static io.netty.util.Recycler<Builder> RECYCLER = new io.netty.util.Recycler<Builder>() {
         protected Builder newObject(io.netty.util.Recycler.Handle handle) {
               return new Builder(handle);
             }
            };
      
       public void recycle() {
                clear();
                if (handle != null) {RECYCLER.recycle(this, handle);}
            }
      
      private void maybeForceBuilderInitialization() {
      }
      private static Builder create() {
        return RECYCLER.get();
      }
      
      public Builder clear() {
        super.clear();
        ledgerId_ = 0L;
        bitField0_ = (bitField0_ & ~0x00000001);
        entryId_ = 0L;
        bitField0_ = (bitField0_ & ~0x00000002);
        return this;
      }
      
      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData getDefaultInstanceForType() {
        return org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData build() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }
      
      private org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData buildParsed()
          throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
        org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(
            result).asInvalidProtocolBufferException();
        }
        return result;
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData buildPartial() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData result = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.RECYCLER.get();
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.ledgerId_ = ledgerId_;
        if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
          to_bitField0_ |= 0x00000002;
        }
        result.entryId_ = entryId_;
        result.bitField0_ = to_bitField0_;
        return result;
      }
      
      public Builder mergeFrom(org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData other) {
        if (other == org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance()) return this;
        if (other.hasLedgerId()) {
          setLedgerId(other.getLedgerId());
        }
        if (other.hasEntryId()) {
          setEntryId(other.getEntryId());
        }
        return this;
      }
      
      public final boolean isInitialized() {
        if (!hasLedgerId()) {
          
          return false;
        }
        if (!hasEntryId()) {
          
          return false;
        }
        return true;
      }
      
      public Builder mergeFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
                              org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
                              throws java.io.IOException {
         throw new java.io.IOException("Merge from CodedInputStream is disabled");
                              }
      public Builder mergeFrom(
          org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream input,
          org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        while (true) {
          int tag = input.readTag();
          switch (tag) {
            case 0:
              
              return this;
            default: {
              if (!input.skipField(tag)) {
                
                return this;
              }
              break;
            }
            case 8: {
              bitField0_ |= 0x00000001;
              ledgerId_ = input.readUInt64();
              break;
            }
            case 16: {
              bitField0_ |= 0x00000002;
              entryId_ = input.readUInt64();
              break;
            }
          }
        }
      }
      
      private int bitField0_;
      
      // required uint64 ledger_id = 1;
      private long ledgerId_ ;
      public boolean hasLedgerId() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      public long getLedgerId() {
        return ledgerId_;
      }
      public Builder setLedgerId(long value) {
        bitField0_ |= 0x00000001;
        ledgerId_ = value;
        
        return this;
      }
      public Builder clearLedgerId() {
        bitField0_ = (bitField0_ & ~0x00000001);
        ledgerId_ = 0L;
        
        return this;
      }
      
      // required uint64 entry_id = 2;
      private long entryId_ ;
      public boolean hasEntryId() {
        return ((bitField0_ & 0x00000002) == 0x00000002);
      }
      public long getEntryId() {
        return entryId_;
      }
      public Builder setEntryId(long value) {
        bitField0_ |= 0x00000002;
        entryId_ = value;
        
        return this;
      }
      public Builder clearEntryId() {
        bitField0_ = (bitField0_ & ~0x00000002);
        entryId_ = 0L;
        
        return this;
      }
      
      // @@protoc_insertion_point(builder_scope:pulsar.proto.MessageIdData)
    }
    
    static {
      defaultInstance = new MessageIdData(true);
      defaultInstance.initFields();
    }
    
    // @@protoc_insertion_point(class_scope:pulsar.proto.MessageIdData)
  }
  
  public interface TxnCommitMarkerOrBuilder
      extends org.apache.pulsar.shaded.com.google.protobuf.v241.MessageLiteOrBuilder {
    
    // required .pulsar.proto.MessageIdData message_id = 1;
    boolean hasMessageId();
    org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData getMessageId();
  }
  public static final class TxnCommitMarker extends
      org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite
      implements TxnCommitMarkerOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage  {
    // Use TxnCommitMarker.newBuilder() to construct.
    private io.netty.util.Recycler.Handle handle;
    private TxnCommitMarker(io.netty.util.Recycler.Handle handle) {
      this.handle = handle;
    }
    
     private static final io.netty.util.Recycler<TxnCommitMarker> RECYCLER = new io.netty.util.Recycler<TxnCommitMarker>() {
            protected TxnCommitMarker newObject(Handle handle) {
              return new TxnCommitMarker(handle);
            }
          };
        
        public void recycle() {
            this.initFields();
            this.memoizedIsInitialized = -1;
            this.bitField0_ = 0;
            this.memoizedSerializedSize = -1;
            if (handle != null) { RECYCLER.recycle(this, handle); }
        }
         
    private TxnCommitMarker(boolean noInit) {}
    
    private static final TxnCommitMarker defaultInstance;
    public static TxnCommitMarker getDefaultInstance() {
      return defaultInstance;
    }
    
    public TxnCommitMarker getDefaultInstanceForType() {
      return defaultInstance;
    }
    
    private int bitField0_;
    // required .pulsar.proto.MessageIdData message_id = 1;
    public static final int MESSAGE_ID_FIELD_NUMBER = 1;
    private org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData messageId_;
    public boolean hasMessageId() {
      return ((bitField0_ & 0x00000001) == 0x00000001);
    }
    public org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData getMessageId() {
      return messageId_;
    }
    
    private void initFields() {
      messageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
    }
    private byte memoizedIsInitialized = -1;
    public final boolean isInitialized() {
      byte isInitialized = memoizedIsInitialized;
      if (isInitialized != -1) return isInitialized == 1;
      
      if (!hasMessageId()) {
        memoizedIsInitialized = 0;
        return false;
      }
      if (!getMessageId().isInitialized()) {
        memoizedIsInitialized = 0;
        return false;
      }
      memoizedIsInitialized = 1;
      return true;
    }
    
    public void writeTo(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream output)
                        throws java.io.IOException {
        throw new RuntimeException("Cannot use CodedOutputStream");
    }
    
    public void writeTo(org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream output)
                        throws java.io.IOException {
      getSerializedSize();
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        output.writeMessage(1, messageId_);
      }
    }
    
    private int memoizedSerializedSize = -1;
    public int getSerializedSize() {
      int size = memoizedSerializedSize;
      if (size != -1) return size;
    
      size = 0;
      if (((bitField0_ & 0x00000001) == 0x00000001)) {
        size += org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream
          .computeMessageSize(1, messageId_);
      }
      memoizedSerializedSize = size;
      return size;
    }
    
    private static final long serialVersionUID = 0L;
    @java.lang.Override
    protected java.lang.Object writeReplace()
        throws java.io.ObjectStreamException {
      return super.writeReplace();
    }
    
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
         throw new RuntimeException("Disabled");
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker parseFrom(byte[] data)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker parseFrom(
        byte[] data,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
      return newBuilder().mergeFrom(data, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker parseFrom(java.io.InputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker parseFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker parseDelimitedFrom(
        java.io.InputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      Builder builder = newBuilder();
      if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
        return builder.buildParsed();
      } else {
        return null;
      }
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input).buildParsed();
    }
    public static org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker parseFrom(
        org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
        org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
      return newBuilder().mergeFrom(input, extensionRegistry)
               .buildParsed();
    }
    
    public static Builder newBuilder() { return Builder.create(); }
    public Builder newBuilderForType() { return newBuilder(); }
    public static Builder newBuilder(org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker prototype) {
      return newBuilder().mergeFrom(prototype);
    }
    public Builder toBuilder() { return newBuilder(this); }
    
    public static final class Builder extends
        org.apache.pulsar.shaded.com.google.protobuf.v241.GeneratedMessageLite.Builder<
          org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker, Builder>
        implements org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarkerOrBuilder, org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder  {
      // Construct using org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker.newBuilder()
      private final io.netty.util.Recycler.Handle handle;
      private Builder(io.netty.util.Recycler.Handle handle) {
        this.handle = handle;
        maybeForceBuilderInitialization();
      }
      private final static io.netty.util.Recycler<Builder> RECYCLER = new io.netty.util.Recycler<Builder>() {
         protected Builder newObject(io.netty.util.Recycler.Handle handle) {
               return new Builder(handle);
             }
            };
      
       public void recycle() {
                clear();
                if (handle != null) {RECYCLER.recycle(this, handle);}
            }
      
      private void maybeForceBuilderInitialization() {
      }
      private static Builder create() {
        return RECYCLER.get();
      }
      
      public Builder clear() {
        super.clear();
        messageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
        bitField0_ = (bitField0_ & ~0x00000001);
        return this;
      }
      
      public Builder clone() {
        return create().mergeFrom(buildPartial());
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker getDefaultInstanceForType() {
        return org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker.getDefaultInstance();
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker build() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(result);
        }
        return result;
      }
      
      private org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker buildParsed()
          throws org.apache.pulsar.shaded.com.google.protobuf.v241.InvalidProtocolBufferException {
        org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker result = buildPartial();
        if (!result.isInitialized()) {
          throw newUninitializedMessageException(
            result).asInvalidProtocolBufferException();
        }
        return result;
      }
      
      public org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker buildPartial() {
        org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker result = org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker.RECYCLER.get();
        int from_bitField0_ = bitField0_;
        int to_bitField0_ = 0;
        if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
          to_bitField0_ |= 0x00000001;
        }
        result.messageId_ = messageId_;
        result.bitField0_ = to_bitField0_;
        return result;
      }
      
      public Builder mergeFrom(org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker other) {
        if (other == org.apache.pulsar.common.api.proto.PulsarMarkers.TxnCommitMarker.getDefaultInstance()) return this;
        if (other.hasMessageId()) {
          mergeMessageId(other.getMessageId());
        }
        return this;
      }
      
      public final boolean isInitialized() {
        if (!hasMessageId()) {
          
          return false;
        }
        if (!getMessageId().isInitialized()) {
          
          return false;
        }
        return true;
      }
      
      public Builder mergeFrom(org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream input,
                              org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
                              throws java.io.IOException {
         throw new java.io.IOException("Merge from CodedInputStream is disabled");
                              }
      public Builder mergeFrom(
          org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream input,
          org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        while (true) {
          int tag = input.readTag();
          switch (tag) {
            case 0:
              
              return this;
            default: {
              if (!input.skipField(tag)) {
                
                return this;
              }
              break;
            }
            case 10: {
              org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.Builder subBuilder = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.newBuilder();
              if (hasMessageId()) {
                subBuilder.mergeFrom(getMessageId());
              }
              input.readMessage(subBuilder, extensionRegistry);
              setMessageId(subBuilder.buildPartial());
              subBuilder.recycle();
              break;
            }
          }
        }
      }
      
      private int bitField0_;
      
      // required .pulsar.proto.MessageIdData message_id = 1;
      private org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData messageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
      public boolean hasMessageId() {
        return ((bitField0_ & 0x00000001) == 0x00000001);
      }
      public org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData getMessageId() {
        return messageId_;
      }
      public Builder setMessageId(org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData value) {
        if (value == null) {
          throw new NullPointerException();
        }
        messageId_ = value;
        
        bitField0_ |= 0x00000001;
        return this;
      }
      public Builder setMessageId(
          org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.Builder builderForValue) {
        messageId_ = builderForValue.build();
        
        bitField0_ |= 0x00000001;
        return this;
      }
      public Builder mergeMessageId(org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData value) {
        if (((bitField0_ & 0x00000001) == 0x00000001) &&
            messageId_ != org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance()) {
          messageId_ =
            org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.newBuilder(messageId_).mergeFrom(value).buildPartial();
        } else {
          messageId_ = value;
        }
        
        bitField0_ |= 0x00000001;
        return this;
      }
      public Builder clearMessageId() {
        messageId_ = org.apache.pulsar.common.api.proto.PulsarMarkers.MessageIdData.getDefaultInstance();
        
        bitField0_ = (bitField0_ & ~0x00000001);
        return this;
      }
      
      // @@protoc_insertion_point(builder_scope:pulsar.proto.TxnCommitMarker)
    }
    
    static {
      defaultInstance = new TxnCommitMarker(true);
      defaultInstance.initFields();
    }
    
    // @@protoc_insertion_point(class_scope:pulsar.proto.TxnCommitMarker)
  }
  
  
  static {
  }
  
  // @@protoc_insertion_point(outer_class_scope)
}
