PulsarApi updated to prepare to support the latest features (#129) The PulsarApi is now updated to Commit id: b0945d1 on Oct 20, 2022, from https://github.com/apache/pulsar/blob/master/pulsar-common/src/main/proto/PulsarApi.proto Co-authored-by: David Jensen <djn@danskecommodities.com>

commit: 6c52a27a4cf1f735a8653948bd3bdd3b8212e344 [log] [tgz]
author: entvex <entvex@users.noreply.github.com> Thu Nov 24 10:55:05 2022 +0100
committer: GitHub <noreply@github.com> Thu Nov 24 10:55:05 2022 +0100
tree: 8af61b4fbfa2dc7a7a1f283b74af8ba546aa7a7f
parent: 9328efa93e9933f6758dbda7a0145fe02e24a229 [diff]
diff --git a/src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs b/src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs
index 3201bf2..fc91175 100644
--- a/src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs
+++ b/src/DotPulsar/Internal/PulsarApi/GeneratedCode.cs

@@ -1,4 +1,4 @@
-/*
+/*
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -13,17 +13,18 @@
  */
 
 #nullable disable
-#region Designer generated code
-#pragma warning disable CS0612, CS0618, CS1591, CS3021, IDE0079, IDE1006, RCS1036, RCS1057, RCS1085, RCS1192
-
-namespace DotPulsar.Internal.PulsarApi;
-
 // <auto-generated>
 //   This file was generated by a tool; you should avoid making direct changes.
 //   Consider using 'partial classes' to extend these types
-//   Input: PulsarApi.proto (281163b)
+//   Input: PulsarApi.proto
+//   Commit id: b0945d1 on Oct 20, 2022 from https://github.com/apache/pulsar/blob/master/pulsar-common/src/main/proto/PulsarApi.proto
 // </auto-generated>
 
+#region Designer generated code
+
+#pragma warning disable CS0612, CS0618, CS1591, CS3021, IDE0079, IDE1006, RCS1036, RCS1057, RCS1085, RCS1192
+namespace DotPulsar.Internal.PulsarApi;
+
 [global::ProtoBuf.ProtoContract()]
 public partial class Schema : global::ProtoBuf.IExtensible
 {
@@ -68,7 +69,6 @@
         LocalDateTime = 19,
         ProtobufNative = 20,
     }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -91,6 +91,7 @@
         get => __pbn__Partition ?? -1;
         set => __pbn__Partition = value;
     }
+
     public bool ShouldSerializePartition() => __pbn__Partition != null;
     public void ResetPartition() => __pbn__Partition = null;
     private int? __pbn__Partition;
@@ -102,6 +103,7 @@
         get => __pbn__BatchIndex ?? -1;
         set => __pbn__BatchIndex = value;
     }
+
     public bool ShouldSerializeBatchIndex() => __pbn__BatchIndex != null;
     public void ResetBatchIndex() => __pbn__BatchIndex = null;
     private int? __pbn__BatchIndex;
@@ -115,10 +117,13 @@
         get => __pbn__BatchSize.GetValueOrDefault();
         set => __pbn__BatchSize = value;
     }
+
     public bool ShouldSerializeBatchSize() => __pbn__BatchSize != null;
     public void ResetBatchSize() => __pbn__BatchSize = null;
     private int? __pbn__BatchSize;
 
+    [global::ProtoBuf.ProtoMember(7, Name = @"first_chunk_message_id")]
+    public MessageIdData FirstChunkMessageId { get; set; }
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -133,7 +138,6 @@
 
     [global::ProtoBuf.ProtoMember(2, Name = @"value", IsRequired = true)]
     public string Value { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -148,7 +152,6 @@
 
     [global::ProtoBuf.ProtoMember(2, Name = @"value", IsRequired = true)]
     public ulong Value { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -163,7 +166,6 @@
 
     [global::ProtoBuf.ProtoMember(2, Name = @"end", IsRequired = true)]
     public int End { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -181,7 +183,6 @@
 
     [global::ProtoBuf.ProtoMember(3, Name = @"metadata")]
     public global::System.Collections.Generic.List<KeyValue> Metadatas { get; } = new global::System.Collections.Generic.List<KeyValue>();
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -210,6 +211,7 @@
         get => __pbn__ReplicatedFrom ?? "";
         set => __pbn__ReplicatedFrom = value;
     }
+
     public bool ShouldSerializeReplicatedFrom() => __pbn__ReplicatedFrom != null;
     public void ResetReplicatedFrom() => __pbn__ReplicatedFrom = null;
     private string __pbn__ReplicatedFrom;
@@ -221,6 +223,7 @@
         get => __pbn__PartitionKey ?? "";
         set => __pbn__PartitionKey = value;
     }
+
     public bool ShouldSerializePartitionKey() => __pbn__PartitionKey != null;
     public void ResetPartitionKey() => __pbn__PartitionKey = null;
     private string __pbn__PartitionKey;
@@ -235,6 +238,7 @@
         get => __pbn__Compression ?? CompressionType.None;
         set => __pbn__Compression = value;
     }
+
     public bool ShouldSerializeCompression() => __pbn__Compression != null;
     public void ResetCompression() => __pbn__Compression = null;
     private CompressionType? __pbn__Compression;
@@ -246,6 +250,7 @@
         get => __pbn__UncompressedSize ?? 0;
         set => __pbn__UncompressedSize = value;
     }
+
     public bool ShouldSerializeUncompressedSize() => __pbn__UncompressedSize != null;
     public void ResetUncompressedSize() => __pbn__UncompressedSize = null;
     private uint? __pbn__UncompressedSize;
@@ -257,6 +262,7 @@
         get => __pbn__NumMessagesInBatch ?? 1;
         set => __pbn__NumMessagesInBatch = value;
     }
+
     public bool ShouldSerializeNumMessagesInBatch() => __pbn__NumMessagesInBatch != null;
     public void ResetNumMessagesInBatch() => __pbn__NumMessagesInBatch = null;
     private int? __pbn__NumMessagesInBatch;
@@ -268,6 +274,7 @@
         get => __pbn__EventTime ?? 0;
         set => __pbn__EventTime = value;
     }
+
     public bool ShouldSerializeEventTime() => __pbn__EventTime != null;
     public void ResetEventTime() => __pbn__EventTime = null;
     private ulong? __pbn__EventTime;
@@ -282,6 +289,7 @@
         get => __pbn__EncryptionAlgo ?? "";
         set => __pbn__EncryptionAlgo = value;
     }
+
     public bool ShouldSerializeEncryptionAlgo() => __pbn__EncryptionAlgo != null;
     public void ResetEncryptionAlgo() => __pbn__EncryptionAlgo = null;
     private string __pbn__EncryptionAlgo;
@@ -292,6 +300,7 @@
         get => __pbn__EncryptionParam;
         set => __pbn__EncryptionParam = value;
     }
+
     public bool ShouldSerializeEncryptionParam() => __pbn__EncryptionParam != null;
     public void ResetEncryptionParam() => __pbn__EncryptionParam = null;
     private byte[] __pbn__EncryptionParam;
@@ -302,6 +311,7 @@
         get => __pbn__SchemaVersion;
         set => __pbn__SchemaVersion = value;
     }
+
     public bool ShouldSerializeSchemaVersion() => __pbn__SchemaVersion != null;
     public void ResetSchemaVersion() => __pbn__SchemaVersion = null;
     private byte[] __pbn__SchemaVersion;
@@ -313,6 +323,7 @@
         get => __pbn__PartitionKeyB64Encoded ?? false;
         set => __pbn__PartitionKeyB64Encoded = value;
     }
+
     public bool ShouldSerializePartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded != null;
     public void ResetPartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded = null;
     private bool? __pbn__PartitionKeyB64Encoded;
@@ -323,6 +334,7 @@
         get => __pbn__OrderingKey;
         set => __pbn__OrderingKey = value;
     }
+
     public bool ShouldSerializeOrderingKey() => __pbn__OrderingKey != null;
     public void ResetOrderingKey() => __pbn__OrderingKey = null;
     private byte[] __pbn__OrderingKey;
@@ -333,6 +345,7 @@
         get => __pbn__DeliverAtTime.GetValueOrDefault();
         set => __pbn__DeliverAtTime = value;
     }
+
     public bool ShouldSerializeDeliverAtTime() => __pbn__DeliverAtTime != null;
     public void ResetDeliverAtTime() => __pbn__DeliverAtTime = null;
     private long? __pbn__DeliverAtTime;
@@ -343,6 +356,7 @@
         get => __pbn__MarkerType.GetValueOrDefault();
         set => __pbn__MarkerType = value;
     }
+
     public bool ShouldSerializeMarkerType() => __pbn__MarkerType != null;
     public void ResetMarkerType() => __pbn__MarkerType = null;
     private int? __pbn__MarkerType;
@@ -353,6 +367,7 @@
         get => __pbn__TxnidLeastBits.GetValueOrDefault();
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -363,6 +378,7 @@
         get => __pbn__TxnidMostBits.GetValueOrDefault();
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -374,6 +390,7 @@
         get => __pbn__HighestSequenceId ?? 0;
         set => __pbn__HighestSequenceId = value;
     }
+
     public bool ShouldSerializeHighestSequenceId() => __pbn__HighestSequenceId != null;
     public void ResetHighestSequenceId() => __pbn__HighestSequenceId = null;
     private ulong? __pbn__HighestSequenceId;
@@ -385,6 +402,7 @@
         get => __pbn__NullValue ?? false;
         set => __pbn__NullValue = value;
     }
+
     public bool ShouldSerializeNullValue() => __pbn__NullValue != null;
     public void ResetNullValue() => __pbn__NullValue = null;
     private bool? __pbn__NullValue;
@@ -396,6 +414,7 @@
         get => __pbn__Uuid ?? "";
         set => __pbn__Uuid = value;
     }
+
     public bool ShouldSerializeUuid() => __pbn__Uuid != null;
     public void ResetUuid() => __pbn__Uuid = null;
     private string __pbn__Uuid;
@@ -406,6 +425,7 @@
         get => __pbn__NumChunksFromMsg.GetValueOrDefault();
         set => __pbn__NumChunksFromMsg = value;
     }
+
     public bool ShouldSerializeNumChunksFromMsg() => __pbn__NumChunksFromMsg != null;
     public void ResetNumChunksFromMsg() => __pbn__NumChunksFromMsg = null;
     private int? __pbn__NumChunksFromMsg;
@@ -416,6 +436,7 @@
         get => __pbn__TotalChunkMsgSize.GetValueOrDefault();
         set => __pbn__TotalChunkMsgSize = value;
     }
+
     public bool ShouldSerializeTotalChunkMsgSize() => __pbn__TotalChunkMsgSize != null;
     public void ResetTotalChunkMsgSize() => __pbn__TotalChunkMsgSize = null;
     private int? __pbn__TotalChunkMsgSize;
@@ -426,6 +447,7 @@
         get => __pbn__ChunkId.GetValueOrDefault();
         set => __pbn__ChunkId = value;
     }
+
     public bool ShouldSerializeChunkId() => __pbn__ChunkId != null;
     public void ResetChunkId() => __pbn__ChunkId = null;
     private int? __pbn__ChunkId;
@@ -437,10 +459,10 @@
         get => __pbn__NullPartitionKey ?? false;
         set => __pbn__NullPartitionKey = value;
     }
+
     public bool ShouldSerializeNullPartitionKey() => __pbn__NullPartitionKey != null;
     public void ResetNullPartitionKey() => __pbn__NullPartitionKey = null;
     private bool? __pbn__NullPartitionKey;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -460,6 +482,7 @@
         get => __pbn__PartitionKey ?? "";
         set => __pbn__PartitionKey = value;
     }
+
     public bool ShouldSerializePartitionKey() => __pbn__PartitionKey != null;
     public void ResetPartitionKey() => __pbn__PartitionKey = null;
     private string __pbn__PartitionKey;
@@ -474,6 +497,7 @@
         get => __pbn__CompactedOut ?? false;
         set => __pbn__CompactedOut = value;
     }
+
     public bool ShouldSerializeCompactedOut() => __pbn__CompactedOut != null;
     public void ResetCompactedOut() => __pbn__CompactedOut = null;
     private bool? __pbn__CompactedOut;
@@ -485,6 +509,7 @@
         get => __pbn__EventTime ?? 0;
         set => __pbn__EventTime = value;
     }
+
     public bool ShouldSerializeEventTime() => __pbn__EventTime != null;
     public void ResetEventTime() => __pbn__EventTime = null;
     private ulong? __pbn__EventTime;
@@ -496,6 +521,7 @@
         get => __pbn__PartitionKeyB64Encoded ?? false;
         set => __pbn__PartitionKeyB64Encoded = value;
     }
+
     public bool ShouldSerializePartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded != null;
     public void ResetPartitionKeyB64Encoded() => __pbn__PartitionKeyB64Encoded = null;
     private bool? __pbn__PartitionKeyB64Encoded;
@@ -506,6 +532,7 @@
         get => __pbn__OrderingKey;
         set => __pbn__OrderingKey = value;
     }
+
     public bool ShouldSerializeOrderingKey() => __pbn__OrderingKey != null;
     public void ResetOrderingKey() => __pbn__OrderingKey = null;
     private byte[] __pbn__OrderingKey;
@@ -516,6 +543,7 @@
         get => __pbn__SequenceId.GetValueOrDefault();
         set => __pbn__SequenceId = value;
     }
+
     public bool ShouldSerializeSequenceId() => __pbn__SequenceId != null;
     public void ResetSequenceId() => __pbn__SequenceId = null;
     private ulong? __pbn__SequenceId;
@@ -527,6 +555,7 @@
         get => __pbn__NullValue ?? false;
         set => __pbn__NullValue = value;
     }
+
     public bool ShouldSerializeNullValue() => __pbn__NullValue != null;
     public void ResetNullValue() => __pbn__NullValue = null;
     private bool? __pbn__NullValue;
@@ -538,10 +567,40 @@
         get => __pbn__NullPartitionKey ?? false;
         set => __pbn__NullPartitionKey = value;
     }
+
     public bool ShouldSerializeNullPartitionKey() => __pbn__NullPartitionKey != null;
     public void ResetNullPartitionKey() => __pbn__NullPartitionKey = null;
     private bool? __pbn__NullPartitionKey;
+}
 
+[global::ProtoBuf.ProtoContract()]
+public partial class BrokerEntryMetadata : global::ProtoBuf.IExtensible
+{
+    private global::ProtoBuf.IExtension __pbn__extensionData;
+    global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+        => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+    [global::ProtoBuf.ProtoMember(1, Name = @"broker_timestamp")]
+    public ulong BrokerTimestamp
+    {
+        get => __pbn__BrokerTimestamp.GetValueOrDefault();
+        set => __pbn__BrokerTimestamp = value;
+    }
+
+    public bool ShouldSerializeBrokerTimestamp() => __pbn__BrokerTimestamp != null;
+    public void ResetBrokerTimestamp() => __pbn__BrokerTimestamp = null;
+    private ulong? __pbn__BrokerTimestamp;
+
+    [global::ProtoBuf.ProtoMember(2, Name = @"index")]
+    public ulong Index
+    {
+        get => __pbn__Index.GetValueOrDefault();
+        set => __pbn__Index = value;
+    }
+
+    public bool ShouldSerializeIndex() => __pbn__Index != null;
+    public void ResetIndex() => __pbn__Index = null;
+    private ulong? __pbn__Index;
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -561,6 +620,7 @@
         get => __pbn__AuthMethod ?? AuthMethod.AuthMethodNone;
         set => __pbn__AuthMethod = value;
     }
+
     public bool ShouldSerializeAuthMethod() => __pbn__AuthMethod != null;
     public void ResetAuthMethod() => __pbn__AuthMethod = null;
     private AuthMethod? __pbn__AuthMethod;
@@ -572,6 +632,7 @@
         get => __pbn__AuthMethodName ?? "";
         set => __pbn__AuthMethodName = value;
     }
+
     public bool ShouldSerializeAuthMethodName() => __pbn__AuthMethodName != null;
     public void ResetAuthMethodName() => __pbn__AuthMethodName = null;
     private string __pbn__AuthMethodName;
@@ -582,6 +643,7 @@
         get => __pbn__AuthData;
         set => __pbn__AuthData = value;
     }
+
     public bool ShouldSerializeAuthData() => __pbn__AuthData != null;
     public void ResetAuthData() => __pbn__AuthData = null;
     private byte[] __pbn__AuthData;
@@ -593,6 +655,7 @@
         get => __pbn__ProtocolVersion ?? 0;
         set => __pbn__ProtocolVersion = value;
     }
+
     public bool ShouldSerializeProtocolVersion() => __pbn__ProtocolVersion != null;
     public void ResetProtocolVersion() => __pbn__ProtocolVersion = null;
     private int? __pbn__ProtocolVersion;
@@ -604,6 +667,7 @@
         get => __pbn__ProxyToBrokerUrl ?? "";
         set => __pbn__ProxyToBrokerUrl = value;
     }
+
     public bool ShouldSerializeProxyToBrokerUrl() => __pbn__ProxyToBrokerUrl != null;
     public void ResetProxyToBrokerUrl() => __pbn__ProxyToBrokerUrl = null;
     private string __pbn__ProxyToBrokerUrl;
@@ -615,6 +679,7 @@
         get => __pbn__OriginalPrincipal ?? "";
         set => __pbn__OriginalPrincipal = value;
     }
+
     public bool ShouldSerializeOriginalPrincipal() => __pbn__OriginalPrincipal != null;
     public void ResetOriginalPrincipal() => __pbn__OriginalPrincipal = null;
     private string __pbn__OriginalPrincipal;
@@ -626,6 +691,7 @@
         get => __pbn__OriginalAuthData ?? "";
         set => __pbn__OriginalAuthData = value;
     }
+
     public bool ShouldSerializeOriginalAuthData() => __pbn__OriginalAuthData != null;
     public void ResetOriginalAuthData() => __pbn__OriginalAuthData = null;
     private string __pbn__OriginalAuthData;
@@ -637,13 +703,13 @@
         get => __pbn__OriginalAuthMethod ?? "";
         set => __pbn__OriginalAuthMethod = value;
     }
+
     public bool ShouldSerializeOriginalAuthMethod() => __pbn__OriginalAuthMethod != null;
     public void ResetOriginalAuthMethod() => __pbn__OriginalAuthMethod = null;
     private string __pbn__OriginalAuthMethod;
 
     [global::ProtoBuf.ProtoMember(10, Name = @"feature_flags")]
     public FeatureFlags FeatureFlags { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -660,10 +726,46 @@
         get => __pbn__SupportsAuthRefresh ?? false;
         set => __pbn__SupportsAuthRefresh = value;
     }
+
     public bool ShouldSerializeSupportsAuthRefresh() => __pbn__SupportsAuthRefresh != null;
     public void ResetSupportsAuthRefresh() => __pbn__SupportsAuthRefresh = null;
     private bool? __pbn__SupportsAuthRefresh;
 
+    [global::ProtoBuf.ProtoMember(2, Name = @"supports_broker_entry_metadata")]
+    [global::System.ComponentModel.DefaultValue(false)]
+    public bool SupportsBrokerEntryMetadata
+    {
+        get => __pbn__SupportsBrokerEntryMetadata ?? false;
+        set => __pbn__SupportsBrokerEntryMetadata = value;
+    }
+
+    public bool ShouldSerializeSupportsBrokerEntryMetadata() => __pbn__SupportsBrokerEntryMetadata != null;
+    public void ResetSupportsBrokerEntryMetadata() => __pbn__SupportsBrokerEntryMetadata = null;
+    private bool? __pbn__SupportsBrokerEntryMetadata;
+
+    [global::ProtoBuf.ProtoMember(3, Name = @"supports_partial_producer")]
+    [global::System.ComponentModel.DefaultValue(false)]
+    public bool SupportsPartialProducer
+    {
+        get => __pbn__SupportsPartialProducer ?? false;
+        set => __pbn__SupportsPartialProducer = value;
+    }
+
+    public bool ShouldSerializeSupportsPartialProducer() => __pbn__SupportsPartialProducer != null;
+    public void ResetSupportsPartialProducer() => __pbn__SupportsPartialProducer = null;
+    private bool? __pbn__SupportsPartialProducer;
+
+    [global::ProtoBuf.ProtoMember(4, Name = @"supports_topic_watchers")]
+    [global::System.ComponentModel.DefaultValue(false)]
+    public bool SupportsTopicWatchers
+    {
+        get => __pbn__SupportsTopicWatchers ?? false;
+        set => __pbn__SupportsTopicWatchers = value;
+    }
+
+    public bool ShouldSerializeSupportsTopicWatchers() => __pbn__SupportsTopicWatchers != null;
+    public void ResetSupportsTopicWatchers() => __pbn__SupportsTopicWatchers = null;
+    private bool? __pbn__SupportsTopicWatchers;
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -683,6 +785,7 @@
         get => __pbn__ProtocolVersion ?? 0;
         set => __pbn__ProtocolVersion = value;
     }
+
     public bool ShouldSerializeProtocolVersion() => __pbn__ProtocolVersion != null;
     public void ResetProtocolVersion() => __pbn__ProtocolVersion = null;
     private int? __pbn__ProtocolVersion;
@@ -693,10 +796,13 @@
         get => __pbn__MaxMessageSize.GetValueOrDefault();
         set => __pbn__MaxMessageSize = value;
     }
+
     public bool ShouldSerializeMaxMessageSize() => __pbn__MaxMessageSize != null;
     public void ResetMaxMessageSize() => __pbn__MaxMessageSize = null;
     private int? __pbn__MaxMessageSize;
 
+    [global::ProtoBuf.ProtoMember(4, Name = @"feature_flags")]
+    public FeatureFlags FeatureFlags { get; set; }
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -713,6 +819,7 @@
         get => __pbn__ClientVersion ?? "";
         set => __pbn__ClientVersion = value;
     }
+
     public bool ShouldSerializeClientVersion() => __pbn__ClientVersion != null;
     public void ResetClientVersion() => __pbn__ClientVersion = null;
     private string __pbn__ClientVersion;
@@ -727,10 +834,10 @@
         get => __pbn__ProtocolVersion ?? 0;
         set => __pbn__ProtocolVersion = value;
     }
+
     public bool ShouldSerializeProtocolVersion() => __pbn__ProtocolVersion != null;
     public void ResetProtocolVersion() => __pbn__ProtocolVersion = null;
     private int? __pbn__ProtocolVersion;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -747,6 +854,7 @@
         get => __pbn__ServerVersion ?? "";
         set => __pbn__ServerVersion = value;
     }
+
     public bool ShouldSerializeServerVersion() => __pbn__ServerVersion != null;
     public void ResetServerVersion() => __pbn__ServerVersion = null;
     private string __pbn__ServerVersion;
@@ -761,10 +869,10 @@
         get => __pbn__ProtocolVersion ?? 0;
         set => __pbn__ProtocolVersion = value;
     }
+
     public bool ShouldSerializeProtocolVersion() => __pbn__ProtocolVersion != null;
     public void ResetProtocolVersion() => __pbn__ProtocolVersion = null;
     private int? __pbn__ProtocolVersion;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -781,6 +889,7 @@
         get => __pbn__AuthMethodName ?? "";
         set => __pbn__AuthMethodName = value;
     }
+
     public bool ShouldSerializeAuthMethodName() => __pbn__AuthMethodName != null;
     public void ResetAuthMethodName() => __pbn__AuthMethodName = null;
     private string __pbn__AuthMethodName;
@@ -791,10 +900,10 @@
         get => __pbn__auth_data;
         set => __pbn__auth_data = value;
     }
+
     public bool ShouldSerializeauth_data() => __pbn__auth_data != null;
     public void Resetauth_data() => __pbn__auth_data = null;
     private byte[] __pbn__auth_data;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -805,7 +914,7 @@
         => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
 
     [global::ProtoBuf.ProtoMember(1, IsRequired = true)]
-    public KeySharedMode KeySharedMode { get; set; }
+    public KeySharedMode keySharedMode { get; set; }
 
     [global::ProtoBuf.ProtoMember(3)]
     public global::System.Collections.Generic.List<IntRange> hashRanges { get; } = new global::System.Collections.Generic.List<IntRange>();
@@ -817,10 +926,10 @@
         get => __pbn__allowOutOfOrderDelivery ?? false;
         set => __pbn__allowOutOfOrderDelivery = value;
     }
+
     public bool ShouldSerializeallowOutOfOrderDelivery() => __pbn__allowOutOfOrderDelivery != null;
     public void ResetallowOutOfOrderDelivery() => __pbn__allowOutOfOrderDelivery = null;
     private bool? __pbn__allowOutOfOrderDelivery;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -852,6 +961,7 @@
         get => __pbn__ConsumerName ?? "";
         set => __pbn__ConsumerName = value;
     }
+
     public bool ShouldSerializeConsumerName() => __pbn__ConsumerName != null;
     public void ResetConsumerName() => __pbn__ConsumerName = null;
     private string __pbn__ConsumerName;
@@ -862,6 +972,7 @@
         get => __pbn__PriorityLevel.GetValueOrDefault();
         set => __pbn__PriorityLevel = value;
     }
+
     public bool ShouldSerializePriorityLevel() => __pbn__PriorityLevel != null;
     public void ResetPriorityLevel() => __pbn__PriorityLevel = null;
     private int? __pbn__PriorityLevel;
@@ -873,6 +984,7 @@
         get => __pbn__Durable ?? true;
         set => __pbn__Durable = value;
     }
+
     public bool ShouldSerializeDurable() => __pbn__Durable != null;
     public void ResetDurable() => __pbn__Durable = null;
     private bool? __pbn__Durable;
@@ -889,6 +1001,7 @@
         get => __pbn__ReadCompacted.GetValueOrDefault();
         set => __pbn__ReadCompacted = value;
     }
+
     public bool ShouldSerializeReadCompacted() => __pbn__ReadCompacted != null;
     public void ResetReadCompacted() => __pbn__ReadCompacted = null;
     private bool? __pbn__ReadCompacted;
@@ -903,6 +1016,7 @@
         get => __pbn__initialPosition ?? InitialPositionType.Latest;
         set => __pbn__initialPosition = value;
     }
+
     public bool ShouldSerializeinitialPosition() => __pbn__initialPosition != null;
     public void ResetinitialPosition() => __pbn__initialPosition = null;
     private InitialPositionType? __pbn__initialPosition;
@@ -913,6 +1027,7 @@
         get => __pbn__ReplicateSubscriptionState.GetValueOrDefault();
         set => __pbn__ReplicateSubscriptionState = value;
     }
+
     public bool ShouldSerializeReplicateSubscriptionState() => __pbn__ReplicateSubscriptionState != null;
     public void ResetReplicateSubscriptionState() => __pbn__ReplicateSubscriptionState = null;
     private bool? __pbn__ReplicateSubscriptionState;
@@ -924,6 +1039,7 @@
         get => __pbn__ForceTopicCreation ?? true;
         set => __pbn__ForceTopicCreation = value;
     }
+
     public bool ShouldSerializeForceTopicCreation() => __pbn__ForceTopicCreation != null;
     public void ResetForceTopicCreation() => __pbn__ForceTopicCreation = null;
     private bool? __pbn__ForceTopicCreation;
@@ -935,12 +1051,27 @@
         get => __pbn__StartMessageRollbackDurationSec ?? 0;
         set => __pbn__StartMessageRollbackDurationSec = value;
     }
+
     public bool ShouldSerializeStartMessageRollbackDurationSec() => __pbn__StartMessageRollbackDurationSec != null;
     public void ResetStartMessageRollbackDurationSec() => __pbn__StartMessageRollbackDurationSec = null;
     private ulong? __pbn__StartMessageRollbackDurationSec;
 
     [global::ProtoBuf.ProtoMember(17)]
-    public KeySharedMeta KeySharedMeta { get; set; }
+    public KeySharedMeta keySharedMeta { get; set; }
+
+    [global::ProtoBuf.ProtoMember(18, Name = @"subscription_properties")]
+    public global::System.Collections.Generic.List<KeyValue> SubscriptionProperties { get; } = new global::System.Collections.Generic.List<KeyValue>();
+
+    [global::ProtoBuf.ProtoMember(19, Name = @"consumer_epoch")]
+    public ulong ConsumerEpoch
+    {
+        get => __pbn__ConsumerEpoch.GetValueOrDefault();
+        set => __pbn__ConsumerEpoch = value;
+    }
+
+    public bool ShouldSerializeConsumerEpoch() => __pbn__ConsumerEpoch != null;
+    public void ResetConsumerEpoch() => __pbn__ConsumerEpoch = null;
+    private ulong? __pbn__ConsumerEpoch;
 
     [global::ProtoBuf.ProtoContract()]
     public enum SubType
@@ -948,6 +1079,7 @@
         Exclusive = 0,
         Shared = 1,
         Failover = 2,
+
         [global::ProtoBuf.ProtoEnum(Name = @"Key_Shared")]
         KeyShared = 3,
     }
@@ -958,7 +1090,6 @@
         Latest = 0,
         Earliest = 1,
     }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -981,6 +1112,7 @@
         get => __pbn__OriginalPrincipal ?? "";
         set => __pbn__OriginalPrincipal = value;
     }
+
     public bool ShouldSerializeOriginalPrincipal() => __pbn__OriginalPrincipal != null;
     public void ResetOriginalPrincipal() => __pbn__OriginalPrincipal = null;
     private string __pbn__OriginalPrincipal;
@@ -992,6 +1124,7 @@
         get => __pbn__OriginalAuthData ?? "";
         set => __pbn__OriginalAuthData = value;
     }
+
     public bool ShouldSerializeOriginalAuthData() => __pbn__OriginalAuthData != null;
     public void ResetOriginalAuthData() => __pbn__OriginalAuthData = null;
     private string __pbn__OriginalAuthData;
@@ -1003,10 +1136,10 @@
         get => __pbn__OriginalAuthMethod ?? "";
         set => __pbn__OriginalAuthMethod = value;
     }
+
     public bool ShouldSerializeOriginalAuthMethod() => __pbn__OriginalAuthMethod != null;
     public void ResetOriginalAuthMethod() => __pbn__OriginalAuthMethod = null;
     private string __pbn__OriginalAuthMethod;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1022,6 +1155,7 @@
         get => __pbn__Partitions.GetValueOrDefault();
         set => __pbn__Partitions = value;
     }
+
     public bool ShouldSerializePartitions() => __pbn__Partitions != null;
     public void ResetPartitions() => __pbn__Partitions = null;
     private uint? __pbn__Partitions;
@@ -1036,6 +1170,7 @@
         get => __pbn__Response ?? LookupType.Success;
         set => __pbn__Response = value;
     }
+
     public bool ShouldSerializeResponse() => __pbn__Response != null;
     public void ResetResponse() => __pbn__Response = null;
     private LookupType? __pbn__Response;
@@ -1047,6 +1182,7 @@
         get => __pbn__Error ?? ServerError.UnknownError;
         set => __pbn__Error = value;
     }
+
     public bool ShouldSerializeError() => __pbn__Error != null;
     public void ResetError() => __pbn__Error = null;
     private ServerError? __pbn__Error;
@@ -1058,6 +1194,7 @@
         get => __pbn__Message ?? "";
         set => __pbn__Message = value;
     }
+
     public bool ShouldSerializeMessage() => __pbn__Message != null;
     public void ResetMessage() => __pbn__Message = null;
     private string __pbn__Message;
@@ -1068,7 +1205,6 @@
         Success = 0,
         Failed = 1,
     }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1091,6 +1227,7 @@
         get => __pbn__Authoritative ?? false;
         set => __pbn__Authoritative = value;
     }
+
     public bool ShouldSerializeAuthoritative() => __pbn__Authoritative != null;
     public void ResetAuthoritative() => __pbn__Authoritative = null;
     private bool? __pbn__Authoritative;
@@ -1102,6 +1239,7 @@
         get => __pbn__OriginalPrincipal ?? "";
         set => __pbn__OriginalPrincipal = value;
     }
+
     public bool ShouldSerializeOriginalPrincipal() => __pbn__OriginalPrincipal != null;
     public void ResetOriginalPrincipal() => __pbn__OriginalPrincipal = null;
     private string __pbn__OriginalPrincipal;
@@ -1113,6 +1251,7 @@
         get => __pbn__OriginalAuthData ?? "";
         set => __pbn__OriginalAuthData = value;
     }
+
     public bool ShouldSerializeOriginalAuthData() => __pbn__OriginalAuthData != null;
     public void ResetOriginalAuthData() => __pbn__OriginalAuthData = null;
     private string __pbn__OriginalAuthData;
@@ -1124,6 +1263,7 @@
         get => __pbn__OriginalAuthMethod ?? "";
         set => __pbn__OriginalAuthMethod = value;
     }
+
     public bool ShouldSerializeOriginalAuthMethod() => __pbn__OriginalAuthMethod != null;
     public void ResetOriginalAuthMethod() => __pbn__OriginalAuthMethod = null;
     private string __pbn__OriginalAuthMethod;
@@ -1135,10 +1275,10 @@
         get => __pbn__AdvertisedListenerName ?? "";
         set => __pbn__AdvertisedListenerName = value;
     }
+
     public bool ShouldSerializeAdvertisedListenerName() => __pbn__AdvertisedListenerName != null;
     public void ResetAdvertisedListenerName() => __pbn__AdvertisedListenerName = null;
     private string __pbn__AdvertisedListenerName;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1155,6 +1295,7 @@
         get => __pbn__brokerServiceUrl ?? "";
         set => __pbn__brokerServiceUrl = value;
     }
+
     public bool ShouldSerializebrokerServiceUrl() => __pbn__brokerServiceUrl != null;
     public void ResetbrokerServiceUrl() => __pbn__brokerServiceUrl = null;
     private string __pbn__brokerServiceUrl;
@@ -1166,6 +1307,7 @@
         get => __pbn__brokerServiceUrlTls ?? "";
         set => __pbn__brokerServiceUrlTls = value;
     }
+
     public bool ShouldSerializebrokerServiceUrlTls() => __pbn__brokerServiceUrlTls != null;
     public void ResetbrokerServiceUrlTls() => __pbn__brokerServiceUrlTls = null;
     private string __pbn__brokerServiceUrlTls;
@@ -1177,6 +1319,7 @@
         get => __pbn__Response ?? LookupType.Redirect;
         set => __pbn__Response = value;
     }
+
     public bool ShouldSerializeResponse() => __pbn__Response != null;
     public void ResetResponse() => __pbn__Response = null;
     private LookupType? __pbn__Response;
@@ -1191,6 +1334,7 @@
         get => __pbn__Authoritative ?? false;
         set => __pbn__Authoritative = value;
     }
+
     public bool ShouldSerializeAuthoritative() => __pbn__Authoritative != null;
     public void ResetAuthoritative() => __pbn__Authoritative = null;
     private bool? __pbn__Authoritative;
@@ -1202,6 +1346,7 @@
         get => __pbn__Error ?? ServerError.UnknownError;
         set => __pbn__Error = value;
     }
+
     public bool ShouldSerializeError() => __pbn__Error != null;
     public void ResetError() => __pbn__Error = null;
     private ServerError? __pbn__Error;
@@ -1213,6 +1358,7 @@
         get => __pbn__Message ?? "";
         set => __pbn__Message = value;
     }
+
     public bool ShouldSerializeMessage() => __pbn__Message != null;
     public void ResetMessage() => __pbn__Message = null;
     private string __pbn__Message;
@@ -1224,6 +1370,7 @@
         get => __pbn__ProxyThroughServiceUrl ?? false;
         set => __pbn__ProxyThroughServiceUrl = value;
     }
+
     public bool ShouldSerializeProxyThroughServiceUrl() => __pbn__ProxyThroughServiceUrl != null;
     public void ResetProxyThroughServiceUrl() => __pbn__ProxyThroughServiceUrl = null;
     private bool? __pbn__ProxyThroughServiceUrl;
@@ -1235,7 +1382,6 @@
         Connect = 1,
         Failed = 2,
     }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1261,6 +1407,7 @@
         get => __pbn__ProducerName ?? "";
         set => __pbn__ProducerName = value;
     }
+
     public bool ShouldSerializeProducerName() => __pbn__ProducerName != null;
     public void ResetProducerName() => __pbn__ProducerName = null;
     private string __pbn__ProducerName;
@@ -1272,6 +1419,7 @@
         get => __pbn__Encrypted ?? false;
         set => __pbn__Encrypted = value;
     }
+
     public bool ShouldSerializeEncrypted() => __pbn__Encrypted != null;
     public void ResetEncrypted() => __pbn__Encrypted = null;
     private bool? __pbn__Encrypted;
@@ -1289,6 +1437,7 @@
         get => __pbn__Epoch ?? 0;
         set => __pbn__Epoch = value;
     }
+
     public bool ShouldSerializeEpoch() => __pbn__Epoch != null;
     public void ResetEpoch() => __pbn__Epoch = null;
     private ulong? __pbn__Epoch;
@@ -1300,10 +1449,57 @@
         get => __pbn__UserProvidedProducerName ?? true;
         set => __pbn__UserProvidedProducerName = value;
     }
+
     public bool ShouldSerializeUserProvidedProducerName() => __pbn__UserProvidedProducerName != null;
     public void ResetUserProvidedProducerName() => __pbn__UserProvidedProducerName = null;
     private bool? __pbn__UserProvidedProducerName;
 
+    [global::ProtoBuf.ProtoMember(10, Name = @"producer_access_mode")]
+    [global::System.ComponentModel.DefaultValue(ProducerAccessMode.Shared)]
+    public ProducerAccessMode ProducerAccessMode
+    {
+        get => __pbn__ProducerAccessMode ?? ProducerAccessMode.Shared;
+        set => __pbn__ProducerAccessMode = value;
+    }
+
+    public bool ShouldSerializeProducerAccessMode() => __pbn__ProducerAccessMode != null;
+    public void ResetProducerAccessMode() => __pbn__ProducerAccessMode = null;
+    private ProducerAccessMode? __pbn__ProducerAccessMode;
+
+    [global::ProtoBuf.ProtoMember(11, Name = @"topic_epoch")]
+    public ulong TopicEpoch
+    {
+        get => __pbn__TopicEpoch.GetValueOrDefault();
+        set => __pbn__TopicEpoch = value;
+    }
+
+    public bool ShouldSerializeTopicEpoch() => __pbn__TopicEpoch != null;
+    public void ResetTopicEpoch() => __pbn__TopicEpoch = null;
+    private ulong? __pbn__TopicEpoch;
+
+    [global::ProtoBuf.ProtoMember(12, Name = @"txn_enabled")]
+    [global::System.ComponentModel.DefaultValue(false)]
+    public bool TxnEnabled
+    {
+        get => __pbn__TxnEnabled ?? false;
+        set => __pbn__TxnEnabled = value;
+    }
+
+    public bool ShouldSerializeTxnEnabled() => __pbn__TxnEnabled != null;
+    public void ResetTxnEnabled() => __pbn__TxnEnabled = null;
+    private bool? __pbn__TxnEnabled;
+
+    [global::ProtoBuf.ProtoMember(13, Name = @"initial_subscription_name")]
+    [global::System.ComponentModel.DefaultValue("")]
+    public string InitialSubscriptionName
+    {
+        get => __pbn__InitialSubscriptionName ?? "";
+        set => __pbn__InitialSubscriptionName = value;
+    }
+
+    public bool ShouldSerializeInitialSubscriptionName() => __pbn__InitialSubscriptionName != null;
+    public void ResetInitialSubscriptionName() => __pbn__InitialSubscriptionName = null;
+    private string __pbn__InitialSubscriptionName;
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1326,6 +1522,7 @@
         get => __pbn__NumMessages ?? 1;
         set => __pbn__NumMessages = value;
     }
+
     public bool ShouldSerializeNumMessages() => __pbn__NumMessages != null;
     public void ResetNumMessages() => __pbn__NumMessages = null;
     private int? __pbn__NumMessages;
@@ -1337,6 +1534,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -1348,6 +1546,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -1359,6 +1558,7 @@
         get => __pbn__HighestSequenceId ?? 0;
         set => __pbn__HighestSequenceId = value;
     }
+
     public bool ShouldSerializeHighestSequenceId() => __pbn__HighestSequenceId != null;
     public void ResetHighestSequenceId() => __pbn__HighestSequenceId = null;
     private ulong? __pbn__HighestSequenceId;
@@ -1370,10 +1570,25 @@
         get => __pbn__IsChunk ?? false;
         set => __pbn__IsChunk = value;
     }
+
     public bool ShouldSerializeIsChunk() => __pbn__IsChunk != null;
     public void ResetIsChunk() => __pbn__IsChunk = null;
     private bool? __pbn__IsChunk;
 
+    [global::ProtoBuf.ProtoMember(8, Name = @"marker")]
+    [global::System.ComponentModel.DefaultValue(false)]
+    public bool Marker
+    {
+        get => __pbn__Marker ?? false;
+        set => __pbn__Marker = value;
+    }
+
+    public bool ShouldSerializeMarker() => __pbn__Marker != null;
+    public void ResetMarker() => __pbn__Marker = null;
+    private bool? __pbn__Marker;
+
+    [global::ProtoBuf.ProtoMember(9, Name = @"message_id")]
+    public MessageIdData MessageId { get; set; }
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1399,10 +1614,10 @@
         get => __pbn__HighestSequenceId ?? 0;
         set => __pbn__HighestSequenceId = value;
     }
+
     public bool ShouldSerializeHighestSequenceId() => __pbn__HighestSequenceId != null;
     public void ResetHighestSequenceId() => __pbn__HighestSequenceId = null;
     private ulong? __pbn__HighestSequenceId;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1423,7 +1638,6 @@
 
     [global::ProtoBuf.ProtoMember(4, Name = @"message", IsRequired = true)]
     public string Message { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1446,6 +1660,7 @@
         get => __pbn__RedeliveryCount ?? 0;
         set => __pbn__RedeliveryCount = value;
     }
+
     public bool ShouldSerializeRedeliveryCount() => __pbn__RedeliveryCount != null;
     public void ResetRedeliveryCount() => __pbn__RedeliveryCount = null;
     private uint? __pbn__RedeliveryCount;
@@ -1453,6 +1668,16 @@
     [global::ProtoBuf.ProtoMember(4, Name = @"ack_set")]
     public long[] AckSets { get; set; }
 
+    [global::ProtoBuf.ProtoMember(5, Name = @"consumer_epoch")]
+    public ulong ConsumerEpoch
+    {
+        get => __pbn__ConsumerEpoch.GetValueOrDefault();
+        set => __pbn__ConsumerEpoch = value;
+    }
+
+    public bool ShouldSerializeConsumerEpoch() => __pbn__ConsumerEpoch != null;
+    public void ResetConsumerEpoch() => __pbn__ConsumerEpoch = null;
+    private ulong? __pbn__ConsumerEpoch;
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1478,6 +1703,7 @@
         get => __pbn__validation_error ?? ValidationErrorType.UncompressedSizeCorruption;
         set => __pbn__validation_error = value;
     }
+
     public bool ShouldSerializevalidation_error() => __pbn__validation_error != null;
     public void Resetvalidation_error() => __pbn__validation_error = null;
     private ValidationErrorType? __pbn__validation_error;
@@ -1492,6 +1718,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -1503,6 +1730,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -1513,6 +1741,7 @@
         get => __pbn__RequestId.GetValueOrDefault();
         set => __pbn__RequestId = value;
     }
+
     public bool ShouldSerializeRequestId() => __pbn__RequestId != null;
     public void ResetRequestId() => __pbn__RequestId = null;
     private ulong? __pbn__RequestId;
@@ -1533,7 +1762,6 @@
         BatchDeSerializeError = 3,
         DecryptionError = 4,
     }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1553,6 +1781,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -1564,6 +1793,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -1575,6 +1805,7 @@
         get => __pbn__Error ?? ServerError.UnknownError;
         set => __pbn__Error = value;
     }
+
     public bool ShouldSerializeError() => __pbn__Error != null;
     public void ResetError() => __pbn__Error = null;
     private ServerError? __pbn__Error;
@@ -1586,6 +1817,7 @@
         get => __pbn__Message ?? "";
         set => __pbn__Message = value;
     }
+
     public bool ShouldSerializeMessage() => __pbn__Message != null;
     public void ResetMessage() => __pbn__Message = null;
     private string __pbn__Message;
@@ -1596,10 +1828,10 @@
         get => __pbn__RequestId.GetValueOrDefault();
         set => __pbn__RequestId = value;
     }
+
     public bool ShouldSerializeRequestId() => __pbn__RequestId != null;
     public void ResetRequestId() => __pbn__RequestId = null;
     private ulong? __pbn__RequestId;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1619,10 +1851,10 @@
         get => __pbn__IsActive ?? false;
         set => __pbn__IsActive = value;
     }
+
     public bool ShouldSerializeIsActive() => __pbn__IsActive != null;
     public void ResetIsActive() => __pbn__IsActive = null;
     private bool? __pbn__IsActive;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1637,7 +1869,6 @@
 
     [global::ProtoBuf.ProtoMember(2, IsRequired = true)]
     public uint MessagePermits { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1652,7 +1883,6 @@
 
     [global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)]
     public ulong RequestId { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1677,10 +1907,10 @@
         get => __pbn__MessagePublishTime.GetValueOrDefault();
         set => __pbn__MessagePublishTime = value;
     }
+
     public bool ShouldSerializeMessagePublishTime() => __pbn__MessagePublishTime != null;
     public void ResetMessagePublishTime() => __pbn__MessagePublishTime = null;
     private ulong? __pbn__MessagePublishTime;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1692,7 +1922,51 @@
 
     [global::ProtoBuf.ProtoMember(1, Name = @"consumer_id", IsRequired = true)]
     public ulong ConsumerId { get; set; }
+}
 
+[global::ProtoBuf.ProtoContract()]
+public partial class CommandTopicMigrated : global::ProtoBuf.IExtensible
+{
+    private global::ProtoBuf.IExtension __pbn__extensionData;
+    global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+        => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+    [global::ProtoBuf.ProtoMember(1, Name = @"resource_id", IsRequired = true)]
+    public ulong ResourceId { get; set; }
+
+    [global::ProtoBuf.ProtoMember(2, IsRequired = true)]
+    public ResourceType resource_type { get; set; }
+
+    [global::ProtoBuf.ProtoMember(3)]
+    [global::System.ComponentModel.DefaultValue("")]
+    public string brokerServiceUrl
+    {
+        get => __pbn__brokerServiceUrl ?? "";
+        set => __pbn__brokerServiceUrl = value;
+    }
+
+    public bool ShouldSerializebrokerServiceUrl() => __pbn__brokerServiceUrl != null;
+    public void ResetbrokerServiceUrl() => __pbn__brokerServiceUrl = null;
+    private string __pbn__brokerServiceUrl;
+
+    [global::ProtoBuf.ProtoMember(4)]
+    [global::System.ComponentModel.DefaultValue("")]
+    public string brokerServiceUrlTls
+    {
+        get => __pbn__brokerServiceUrlTls ?? "";
+        set => __pbn__brokerServiceUrlTls = value;
+    }
+
+    public bool ShouldSerializebrokerServiceUrlTls() => __pbn__brokerServiceUrlTls != null;
+    public void ResetbrokerServiceUrlTls() => __pbn__brokerServiceUrlTls = null;
+    private string __pbn__brokerServiceUrlTls;
+
+    [global::ProtoBuf.ProtoContract()]
+    public enum ResourceType
+    {
+        Producer = 0,
+        Consumer = 1,
+    }
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1707,7 +1981,6 @@
 
     [global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)]
     public ulong RequestId { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1722,7 +1995,6 @@
 
     [global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)]
     public ulong RequestId { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1738,6 +2010,16 @@
     [global::ProtoBuf.ProtoMember(2, Name = @"message_ids")]
     public global::System.Collections.Generic.List<MessageIdData> MessageIds { get; } = new global::System.Collections.Generic.List<MessageIdData>();
 
+    [global::ProtoBuf.ProtoMember(3, Name = @"consumer_epoch")]
+    public ulong ConsumerEpoch
+    {
+        get => __pbn__ConsumerEpoch.GetValueOrDefault();
+        set => __pbn__ConsumerEpoch = value;
+    }
+
+    public bool ShouldSerializeConsumerEpoch() => __pbn__ConsumerEpoch != null;
+    public void ResetConsumerEpoch() => __pbn__ConsumerEpoch = null;
+    private ulong? __pbn__ConsumerEpoch;
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1752,7 +2034,6 @@
 
     [global::ProtoBuf.ProtoMember(2, Name = @"schema")]
     public Schema Schema { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1775,6 +2056,7 @@
         get => __pbn__LastSequenceId ?? -1;
         set => __pbn__LastSequenceId = value;
     }
+
     public bool ShouldSerializeLastSequenceId() => __pbn__LastSequenceId != null;
     public void ResetLastSequenceId() => __pbn__LastSequenceId = null;
     private long? __pbn__LastSequenceId;
@@ -1785,10 +2067,33 @@
         get => __pbn__SchemaVersion;
         set => __pbn__SchemaVersion = value;
     }
+
     public bool ShouldSerializeSchemaVersion() => __pbn__SchemaVersion != null;
     public void ResetSchemaVersion() => __pbn__SchemaVersion = null;
     private byte[] __pbn__SchemaVersion;
 
+    [global::ProtoBuf.ProtoMember(5, Name = @"topic_epoch")]
+    public ulong TopicEpoch
+    {
+        get => __pbn__TopicEpoch.GetValueOrDefault();
+        set => __pbn__TopicEpoch = value;
+    }
+
+    public bool ShouldSerializeTopicEpoch() => __pbn__TopicEpoch != null;
+    public void ResetTopicEpoch() => __pbn__TopicEpoch = null;
+    private ulong? __pbn__TopicEpoch;
+
+    [global::ProtoBuf.ProtoMember(6, Name = @"producer_ready")]
+    [global::System.ComponentModel.DefaultValue(true)]
+    public bool ProducerReady
+    {
+        get => __pbn__ProducerReady ?? true;
+        set => __pbn__ProducerReady = value;
+    }
+
+    public bool ShouldSerializeProducerReady() => __pbn__ProducerReady != null;
+    public void ResetProducerReady() => __pbn__ProducerReady = null;
+    private bool? __pbn__ProducerReady;
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1806,7 +2111,6 @@
 
     [global::ProtoBuf.ProtoMember(3, Name = @"message", IsRequired = true)]
     public string Message { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1815,7 +2119,6 @@
     private global::ProtoBuf.IExtension __pbn__extensionData;
     global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
         => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1824,7 +2127,6 @@
     private global::ProtoBuf.IExtension __pbn__extensionData;
     global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
         => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1839,7 +2141,6 @@
 
     [global::ProtoBuf.ProtoMember(4, Name = @"consumer_id", IsRequired = true)]
     public ulong ConsumerId { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -1859,6 +2160,7 @@
         get => __pbn__ErrorCode ?? ServerError.UnknownError;
         set => __pbn__ErrorCode = value;
     }
+
     public bool ShouldSerializeErrorCode() => __pbn__ErrorCode != null;
     public void ResetErrorCode() => __pbn__ErrorCode = null;
     private ServerError? __pbn__ErrorCode;
@@ -1870,77 +2172,85 @@
         get => __pbn__ErrorMessage ?? "";
         set => __pbn__ErrorMessage = value;
     }
+
     public bool ShouldSerializeErrorMessage() => __pbn__ErrorMessage != null;
     public void ResetErrorMessage() => __pbn__ErrorMessage = null;
     private string __pbn__ErrorMessage;
 
     [global::ProtoBuf.ProtoMember(4)]
-    public double MsgRateOut
+    public double msgRateOut
     {
         get => __pbn__msgRateOut.GetValueOrDefault();
         set => __pbn__msgRateOut = value;
     }
+
     public bool ShouldSerializemsgRateOut() => __pbn__msgRateOut != null;
     public void ResetmsgRateOut() => __pbn__msgRateOut = null;
     private double? __pbn__msgRateOut;
 
     [global::ProtoBuf.ProtoMember(5)]
-    public double MsgThroughputOut
+    public double msgThroughputOut
     {
         get => __pbn__msgThroughputOut.GetValueOrDefault();
         set => __pbn__msgThroughputOut = value;
     }
+
     public bool ShouldSerializemsgThroughputOut() => __pbn__msgThroughputOut != null;
     public void ResetmsgThroughputOut() => __pbn__msgThroughputOut = null;
     private double? __pbn__msgThroughputOut;
 
     [global::ProtoBuf.ProtoMember(6)]
-    public double MsgRateRedeliver
+    public double msgRateRedeliver
     {
         get => __pbn__msgRateRedeliver.GetValueOrDefault();
         set => __pbn__msgRateRedeliver = value;
     }
+
     public bool ShouldSerializemsgRateRedeliver() => __pbn__msgRateRedeliver != null;
     public void ResetmsgRateRedeliver() => __pbn__msgRateRedeliver = null;
     private double? __pbn__msgRateRedeliver;
 
     [global::ProtoBuf.ProtoMember(7)]
     [global::System.ComponentModel.DefaultValue("")]
-    public string ConsumerName
+    public string consumerName
     {
         get => __pbn__consumerName ?? "";
         set => __pbn__consumerName = value;
     }
+
     public bool ShouldSerializeconsumerName() => __pbn__consumerName != null;
     public void ResetconsumerName() => __pbn__consumerName = null;
     private string __pbn__consumerName;
 
     [global::ProtoBuf.ProtoMember(8)]
-    public ulong AvailablePermits
+    public ulong availablePermits
     {
         get => __pbn__availablePermits.GetValueOrDefault();
         set => __pbn__availablePermits = value;
     }
+
     public bool ShouldSerializeavailablePermits() => __pbn__availablePermits != null;
     public void ResetavailablePermits() => __pbn__availablePermits = null;
     private ulong? __pbn__availablePermits;
 
     [global::ProtoBuf.ProtoMember(9)]
-    public ulong UnackedMessages
+    public ulong unackedMessages
     {
         get => __pbn__unackedMessages.GetValueOrDefault();
         set => __pbn__unackedMessages = value;
     }
+
     public bool ShouldSerializeunackedMessages() => __pbn__unackedMessages != null;
     public void ResetunackedMessages() => __pbn__unackedMessages = null;
     private ulong? __pbn__unackedMessages;
 
     [global::ProtoBuf.ProtoMember(10)]
-    public bool BlockedConsumerOnUnackedMsgs
+    public bool blockedConsumerOnUnackedMsgs
     {
         get => __pbn__blockedConsumerOnUnackedMsgs.GetValueOrDefault();
         set => __pbn__blockedConsumerOnUnackedMsgs = value;
     }
+
     public bool ShouldSerializeblockedConsumerOnUnackedMsgs() => __pbn__blockedConsumerOnUnackedMsgs != null;
     public void ResetblockedConsumerOnUnackedMsgs() => __pbn__blockedConsumerOnUnackedMsgs = null;
     private bool? __pbn__blockedConsumerOnUnackedMsgs;
@@ -1952,17 +2262,19 @@
         get => __pbn__Address ?? "";
         set => __pbn__Address = value;
     }
+
     public bool ShouldSerializeAddress() => __pbn__Address != null;
     public void ResetAddress() => __pbn__Address = null;
     private string __pbn__Address;
 
     [global::ProtoBuf.ProtoMember(12)]
     [global::System.ComponentModel.DefaultValue("")]
-    public string ConnectedSince
+    public string connectedSince
     {
         get => __pbn__connectedSince ?? "";
         set => __pbn__connectedSince = value;
     }
+
     public bool ShouldSerializeconnectedSince() => __pbn__connectedSince != null;
     public void ResetconnectedSince() => __pbn__connectedSince = null;
     private string __pbn__connectedSince;
@@ -1974,30 +2286,43 @@
         get => __pbn__Type ?? "";
         set => __pbn__Type = value;
     }
+
     public bool ShouldSerializeType() => __pbn__Type != null;
     public void ResetType() => __pbn__Type = null;
     private string __pbn__Type;
 
     [global::ProtoBuf.ProtoMember(14)]
-    public double MsgRateExpired
+    public double msgRateExpired
     {
         get => __pbn__msgRateExpired.GetValueOrDefault();
         set => __pbn__msgRateExpired = value;
     }
+
     public bool ShouldSerializemsgRateExpired() => __pbn__msgRateExpired != null;
     public void ResetmsgRateExpired() => __pbn__msgRateExpired = null;
     private double? __pbn__msgRateExpired;
 
     [global::ProtoBuf.ProtoMember(15)]
-    public ulong MsgBacklog
+    public ulong msgBacklog
     {
         get => __pbn__msgBacklog.GetValueOrDefault();
         set => __pbn__msgBacklog = value;
     }
+
     public bool ShouldSerializemsgBacklog() => __pbn__msgBacklog != null;
     public void ResetmsgBacklog() => __pbn__msgBacklog = null;
     private ulong? __pbn__msgBacklog;
 
+    [global::ProtoBuf.ProtoMember(16)]
+    public double messageAckRate
+    {
+        get => __pbn__messageAckRate.GetValueOrDefault();
+        set => __pbn__messageAckRate = value;
+    }
+
+    public bool ShouldSerializemessageAckRate() => __pbn__messageAckRate != null;
+    public void ResetmessageAckRate() => __pbn__messageAckRate = null;
+    private double? __pbn__messageAckRate;
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2012,7 +2337,6 @@
 
     [global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)]
     public ulong RequestId { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2028,6 +2352,8 @@
     [global::ProtoBuf.ProtoMember(2, Name = @"request_id", IsRequired = true)]
     public ulong RequestId { get; set; }
 
+    [global::ProtoBuf.ProtoMember(3, Name = @"consumer_mark_delete_position")]
+    public MessageIdData ConsumerMarkDeletePosition { get; set; }
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2044,27 +2370,53 @@
     public string Namespace { get; set; }
 
     [global::ProtoBuf.ProtoMember(3)]
-    [global::System.ComponentModel.DefaultValue(ModeType.Persistent)]
-    public ModeType Mode
+    [global::System.ComponentModel.DefaultValue(Mode.Persistent)]
+    public Mode mode
     {
-        get => __pbn__mode ?? ModeType.Persistent;
+        get => __pbn__mode ?? Mode.Persistent;
         set => __pbn__mode = value;
     }
+
     public bool ShouldSerializemode() => __pbn__mode != null;
     public void Resetmode() => __pbn__mode = null;
-    private ModeType? __pbn__mode;
+    private Mode? __pbn__mode;
+
+    [global::ProtoBuf.ProtoMember(4, Name = @"topics_pattern")]
+    [global::System.ComponentModel.DefaultValue("")]
+    public string TopicsPattern
+    {
+        get => __pbn__TopicsPattern ?? "";
+        set => __pbn__TopicsPattern = value;
+    }
+
+    public bool ShouldSerializeTopicsPattern() => __pbn__TopicsPattern != null;
+    public void ResetTopicsPattern() => __pbn__TopicsPattern = null;
+    private string __pbn__TopicsPattern;
+
+    [global::ProtoBuf.ProtoMember(5, Name = @"topics_hash")]
+    [global::System.ComponentModel.DefaultValue("")]
+    public string TopicsHash
+    {
+        get => __pbn__TopicsHash ?? "";
+        set => __pbn__TopicsHash = value;
+    }
+
+    public bool ShouldSerializeTopicsHash() => __pbn__TopicsHash != null;
+    public void ResetTopicsHash() => __pbn__TopicsHash = null;
+    private string __pbn__TopicsHash;
 
     [global::ProtoBuf.ProtoContract()]
-    public enum ModeType
+    public enum Mode
     {
         [global::ProtoBuf.ProtoEnum(Name = @"PERSISTENT")]
         Persistent = 0,
+
         [global::ProtoBuf.ProtoEnum(Name = @"NON_PERSISTENT")]
         NonPersistent = 1,
+
         [global::ProtoBuf.ProtoEnum(Name = @"ALL")]
         All = 2,
     }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2080,6 +2432,127 @@
     [global::ProtoBuf.ProtoMember(2, Name = @"topics")]
     public global::System.Collections.Generic.List<string> Topics { get; } = new global::System.Collections.Generic.List<string>();
 
+    [global::ProtoBuf.ProtoMember(3, Name = @"filtered")]
+    [global::System.ComponentModel.DefaultValue(false)]
+    public bool Filtered
+    {
+        get => __pbn__Filtered ?? false;
+        set => __pbn__Filtered = value;
+    }
+
+    public bool ShouldSerializeFiltered() => __pbn__Filtered != null;
+    public void ResetFiltered() => __pbn__Filtered = null;
+    private bool? __pbn__Filtered;
+
+    [global::ProtoBuf.ProtoMember(4, Name = @"topics_hash")]
+    [global::System.ComponentModel.DefaultValue("")]
+    public string TopicsHash
+    {
+        get => __pbn__TopicsHash ?? "";
+        set => __pbn__TopicsHash = value;
+    }
+
+    public bool ShouldSerializeTopicsHash() => __pbn__TopicsHash != null;
+    public void ResetTopicsHash() => __pbn__TopicsHash = null;
+    private string __pbn__TopicsHash;
+
+    [global::ProtoBuf.ProtoMember(5, Name = @"changed")]
+    [global::System.ComponentModel.DefaultValue(true)]
+    public bool Changed
+    {
+        get => __pbn__Changed ?? true;
+        set => __pbn__Changed = value;
+    }
+
+    public bool ShouldSerializeChanged() => __pbn__Changed != null;
+    public void ResetChanged() => __pbn__Changed = null;
+    private bool? __pbn__Changed;
+}
+
+[global::ProtoBuf.ProtoContract()]
+public partial class CommandWatchTopicList : global::ProtoBuf.IExtensible
+{
+    private global::ProtoBuf.IExtension __pbn__extensionData;
+    global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+        => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+    [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+    public ulong RequestId { get; set; }
+
+    [global::ProtoBuf.ProtoMember(2, Name = @"watcher_id", IsRequired = true)]
+    public ulong WatcherId { get; set; }
+
+    [global::ProtoBuf.ProtoMember(3, Name = @"namespace", IsRequired = true)]
+    public string Namespace { get; set; }
+
+    [global::ProtoBuf.ProtoMember(4, Name = @"topics_pattern", IsRequired = true)]
+    public string TopicsPattern { get; set; }
+
+    [global::ProtoBuf.ProtoMember(5, Name = @"topics_hash")]
+    [global::System.ComponentModel.DefaultValue("")]
+    public string TopicsHash
+    {
+        get => __pbn__TopicsHash ?? "";
+        set => __pbn__TopicsHash = value;
+    }
+
+    public bool ShouldSerializeTopicsHash() => __pbn__TopicsHash != null;
+    public void ResetTopicsHash() => __pbn__TopicsHash = null;
+    private string __pbn__TopicsHash;
+}
+
+[global::ProtoBuf.ProtoContract()]
+public partial class CommandWatchTopicListSuccess : global::ProtoBuf.IExtensible
+{
+    private global::ProtoBuf.IExtension __pbn__extensionData;
+    global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+        => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+    [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+    public ulong RequestId { get; set; }
+
+    [global::ProtoBuf.ProtoMember(2, Name = @"watcher_id", IsRequired = true)]
+    public ulong WatcherId { get; set; }
+
+    [global::ProtoBuf.ProtoMember(3, Name = @"topic")]
+    public global::System.Collections.Generic.List<string> Topics { get; } = new global::System.Collections.Generic.List<string>();
+
+    [global::ProtoBuf.ProtoMember(4, Name = @"topics_hash", IsRequired = true)]
+    public string TopicsHash { get; set; }
+}
+
+[global::ProtoBuf.ProtoContract()]
+public partial class CommandWatchTopicUpdate : global::ProtoBuf.IExtensible
+{
+    private global::ProtoBuf.IExtension __pbn__extensionData;
+    global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+        => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+    [global::ProtoBuf.ProtoMember(1, Name = @"watcher_id", IsRequired = true)]
+    public ulong WatcherId { get; set; }
+
+    [global::ProtoBuf.ProtoMember(2, Name = @"new_topics")]
+    public global::System.Collections.Generic.List<string> NewTopics { get; } = new global::System.Collections.Generic.List<string>();
+
+    [global::ProtoBuf.ProtoMember(3, Name = @"deleted_topics")]
+    public global::System.Collections.Generic.List<string> DeletedTopics { get; } = new global::System.Collections.Generic.List<string>();
+
+    [global::ProtoBuf.ProtoMember(4, Name = @"topics_hash", IsRequired = true)]
+    public string TopicsHash { get; set; }
+}
+
+[global::ProtoBuf.ProtoContract()]
+public partial class CommandWatchTopicListClose : global::ProtoBuf.IExtensible
+{
+    private global::ProtoBuf.IExtension __pbn__extensionData;
+    global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+        => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+    [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+    public ulong RequestId { get; set; }
+
+    [global::ProtoBuf.ProtoMember(2, Name = @"watcher_id", IsRequired = true)]
+    public ulong WatcherId { get; set; }
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2101,10 +2574,10 @@
         get => __pbn__SchemaVersion;
         set => __pbn__SchemaVersion = value;
     }
+
     public bool ShouldSerializeSchemaVersion() => __pbn__SchemaVersion != null;
     public void ResetSchemaVersion() => __pbn__SchemaVersion = null;
     private byte[] __pbn__SchemaVersion;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2124,6 +2597,7 @@
         get => __pbn__ErrorCode ?? ServerError.UnknownError;
         set => __pbn__ErrorCode = value;
     }
+
     public bool ShouldSerializeErrorCode() => __pbn__ErrorCode != null;
     public void ResetErrorCode() => __pbn__ErrorCode = null;
     private ServerError? __pbn__ErrorCode;
@@ -2135,6 +2609,7 @@
         get => __pbn__ErrorMessage ?? "";
         set => __pbn__ErrorMessage = value;
     }
+
     public bool ShouldSerializeErrorMessage() => __pbn__ErrorMessage != null;
     public void ResetErrorMessage() => __pbn__ErrorMessage = null;
     private string __pbn__ErrorMessage;
@@ -2148,10 +2623,10 @@
         get => __pbn__SchemaVersion;
         set => __pbn__SchemaVersion = value;
     }
+
     public bool ShouldSerializeSchemaVersion() => __pbn__SchemaVersion != null;
     public void ResetSchemaVersion() => __pbn__SchemaVersion = null;
     private byte[] __pbn__SchemaVersion;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2169,7 +2644,6 @@
 
     [global::ProtoBuf.ProtoMember(3, Name = @"schema", IsRequired = true)]
     public Schema Schema { get; set; }
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2189,6 +2663,7 @@
         get => __pbn__ErrorCode ?? ServerError.UnknownError;
         set => __pbn__ErrorCode = value;
     }
+
     public bool ShouldSerializeErrorCode() => __pbn__ErrorCode != null;
     public void ResetErrorCode() => __pbn__ErrorCode = null;
     private ServerError? __pbn__ErrorCode;
@@ -2200,6 +2675,7 @@
         get => __pbn__ErrorMessage ?? "";
         set => __pbn__ErrorMessage = value;
     }
+
     public bool ShouldSerializeErrorMessage() => __pbn__ErrorMessage != null;
     public void ResetErrorMessage() => __pbn__ErrorMessage = null;
     private string __pbn__ErrorMessage;
@@ -2210,10 +2686,59 @@
         get => __pbn__SchemaVersion;
         set => __pbn__SchemaVersion = value;
     }
+
     public bool ShouldSerializeSchemaVersion() => __pbn__SchemaVersion != null;
     public void ResetSchemaVersion() => __pbn__SchemaVersion = null;
     private byte[] __pbn__SchemaVersion;
+}
 
+[global::ProtoBuf.ProtoContract()]
+public partial class CommandTcClientConnectRequest : global::ProtoBuf.IExtensible
+{
+    private global::ProtoBuf.IExtension __pbn__extensionData;
+    global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+        => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+    [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+    public ulong RequestId { get; set; }
+
+    [global::ProtoBuf.ProtoMember(2, Name = @"tc_id", IsRequired = true)]
+    public ulong TcId { get; set; }
+}
+
+[global::ProtoBuf.ProtoContract()]
+public partial class CommandTcClientConnectResponse : global::ProtoBuf.IExtensible
+{
+    private global::ProtoBuf.IExtension __pbn__extensionData;
+    global::ProtoBuf.IExtension global::ProtoBuf.IExtensible.GetExtensionObject(bool createIfMissing)
+        => global::ProtoBuf.Extensible.GetExtensionObject(ref __pbn__extensionData, createIfMissing);
+
+    [global::ProtoBuf.ProtoMember(1, Name = @"request_id", IsRequired = true)]
+    public ulong RequestId { get; set; }
+
+    [global::ProtoBuf.ProtoMember(2, Name = @"error")]
+    [global::System.ComponentModel.DefaultValue(ServerError.UnknownError)]
+    public ServerError Error
+    {
+        get => __pbn__Error ?? ServerError.UnknownError;
+        set => __pbn__Error = value;
+    }
+
+    public bool ShouldSerializeError() => __pbn__Error != null;
+    public void ResetError() => __pbn__Error = null;
+    private ServerError? __pbn__Error;
+
+    [global::ProtoBuf.ProtoMember(3, Name = @"message")]
+    [global::System.ComponentModel.DefaultValue("")]
+    public string Message
+    {
+        get => __pbn__Message ?? "";
+        set => __pbn__Message = value;
+    }
+
+    public bool ShouldSerializeMessage() => __pbn__Message != null;
+    public void ResetMessage() => __pbn__Message = null;
+    private string __pbn__Message;
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2233,6 +2758,7 @@
         get => __pbn__TxnTtlSeconds ?? 0;
         set => __pbn__TxnTtlSeconds = value;
     }
+
     public bool ShouldSerializeTxnTtlSeconds() => __pbn__TxnTtlSeconds != null;
     public void ResetTxnTtlSeconds() => __pbn__TxnTtlSeconds = null;
     private ulong? __pbn__TxnTtlSeconds;
@@ -2244,10 +2770,10 @@
         get => __pbn__TcId ?? 0;
         set => __pbn__TcId = value;
     }
+
     public bool ShouldSerializeTcId() => __pbn__TcId != null;
     public void ResetTcId() => __pbn__TcId = null;
     private ulong? __pbn__TcId;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2267,6 +2793,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2278,6 +2805,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -2289,6 +2817,7 @@
         get => __pbn__Error ?? ServerError.UnknownError;
         set => __pbn__Error = value;
     }
+
     public bool ShouldSerializeError() => __pbn__Error != null;
     public void ResetError() => __pbn__Error = null;
     private ServerError? __pbn__Error;
@@ -2300,10 +2829,10 @@
         get => __pbn__Message ?? "";
         set => __pbn__Message = value;
     }
+
     public bool ShouldSerializeMessage() => __pbn__Message != null;
     public void ResetMessage() => __pbn__Message = null;
     private string __pbn__Message;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2323,6 +2852,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2334,13 +2864,13 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
 
     [global::ProtoBuf.ProtoMember(4, Name = @"partitions")]
     public global::System.Collections.Generic.List<string> Partitions { get; } = new global::System.Collections.Generic.List<string>();
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2360,6 +2890,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2371,6 +2902,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -2382,6 +2914,7 @@
         get => __pbn__Error ?? ServerError.UnknownError;
         set => __pbn__Error = value;
     }
+
     public bool ShouldSerializeError() => __pbn__Error != null;
     public void ResetError() => __pbn__Error = null;
     private ServerError? __pbn__Error;
@@ -2393,10 +2926,10 @@
         get => __pbn__Message ?? "";
         set => __pbn__Message = value;
     }
+
     public bool ShouldSerializeMessage() => __pbn__Message != null;
     public void ResetMessage() => __pbn__Message = null;
     private string __pbn__Message;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2410,8 +2943,7 @@
     public string Topic { get; set; }
 
     [global::ProtoBuf.ProtoMember(2, IsRequired = true)]
-    public string SubscriptionName { get; set; }
-
+    public string subscription { get; set; }
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2431,6 +2963,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2442,13 +2975,13 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
 
     [global::ProtoBuf.ProtoMember(4, Name = @"subscription")]
     public global::System.Collections.Generic.List<Subscription> Subscriptions { get; } = new global::System.Collections.Generic.List<Subscription>();
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2468,6 +3001,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2479,6 +3013,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -2490,6 +3025,7 @@
         get => __pbn__Error ?? ServerError.UnknownError;
         set => __pbn__Error = value;
     }
+
     public bool ShouldSerializeError() => __pbn__Error != null;
     public void ResetError() => __pbn__Error = null;
     private ServerError? __pbn__Error;
@@ -2501,10 +3037,10 @@
         get => __pbn__Message ?? "";
         set => __pbn__Message = value;
     }
+
     public bool ShouldSerializeMessage() => __pbn__Message != null;
     public void ResetMessage() => __pbn__Message = null;
     private string __pbn__Message;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2524,6 +3060,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2535,6 +3072,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -2546,13 +3084,10 @@
         get => __pbn__TxnAction ?? TxnAction.Commit;
         set => __pbn__TxnAction = value;
     }
+
     public bool ShouldSerializeTxnAction() => __pbn__TxnAction != null;
     public void ResetTxnAction() => __pbn__TxnAction = null;
     private TxnAction? __pbn__TxnAction;
-
-    [global::ProtoBuf.ProtoMember(5, Name = @"message_id")]
-    public global::System.Collections.Generic.List<MessageIdData> MessageIds { get; } = new global::System.Collections.Generic.List<MessageIdData>();
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2572,6 +3107,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2583,6 +3119,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -2594,6 +3131,7 @@
         get => __pbn__Error ?? ServerError.UnknownError;
         set => __pbn__Error = value;
     }
+
     public bool ShouldSerializeError() => __pbn__Error != null;
     public void ResetError() => __pbn__Error = null;
     private ServerError? __pbn__Error;
@@ -2605,10 +3143,10 @@
         get => __pbn__Message ?? "";
         set => __pbn__Message = value;
     }
+
     public bool ShouldSerializeMessage() => __pbn__Message != null;
     public void ResetMessage() => __pbn__Message = null;
     private string __pbn__Message;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2628,6 +3166,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2639,6 +3178,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -2650,6 +3190,7 @@
         get => __pbn__Topic ?? "";
         set => __pbn__Topic = value;
     }
+
     public bool ShouldSerializeTopic() => __pbn__Topic != null;
     public void ResetTopic() => __pbn__Topic = null;
     private string __pbn__Topic;
@@ -2661,13 +3202,21 @@
         get => __pbn__TxnAction ?? TxnAction.Commit;
         set => __pbn__TxnAction = value;
     }
+
     public bool ShouldSerializeTxnAction() => __pbn__TxnAction != null;
     public void ResetTxnAction() => __pbn__TxnAction = null;
     private TxnAction? __pbn__TxnAction;
 
-    [global::ProtoBuf.ProtoMember(6, Name = @"message_id")]
-    public global::System.Collections.Generic.List<MessageIdData> MessageIds { get; } = new global::System.Collections.Generic.List<MessageIdData>();
+    [global::ProtoBuf.ProtoMember(6, Name = @"txnid_least_bits_of_low_watermark")]
+    public ulong TxnidLeastBitsOfLowWatermark
+    {
+        get => __pbn__TxnidLeastBitsOfLowWatermark.GetValueOrDefault();
+        set => __pbn__TxnidLeastBitsOfLowWatermark = value;
+    }
 
+    public bool ShouldSerializeTxnidLeastBitsOfLowWatermark() => __pbn__TxnidLeastBitsOfLowWatermark != null;
+    public void ResetTxnidLeastBitsOfLowWatermark() => __pbn__TxnidLeastBitsOfLowWatermark = null;
+    private ulong? __pbn__TxnidLeastBitsOfLowWatermark;
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2687,6 +3236,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2698,6 +3248,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -2709,6 +3260,7 @@
         get => __pbn__Error ?? ServerError.UnknownError;
         set => __pbn__Error = value;
     }
+
     public bool ShouldSerializeError() => __pbn__Error != null;
     public void ResetError() => __pbn__Error = null;
     private ServerError? __pbn__Error;
@@ -2720,10 +3272,10 @@
         get => __pbn__Message ?? "";
         set => __pbn__Message = value;
     }
+
     public bool ShouldSerializeMessage() => __pbn__Message != null;
     public void ResetMessage() => __pbn__Message = null;
     private string __pbn__Message;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2743,6 +3295,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2754,6 +3307,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -2768,10 +3322,21 @@
         get => __pbn__TxnAction ?? TxnAction.Commit;
         set => __pbn__TxnAction = value;
     }
+
     public bool ShouldSerializeTxnAction() => __pbn__TxnAction != null;
     public void ResetTxnAction() => __pbn__TxnAction = null;
     private TxnAction? __pbn__TxnAction;
 
+    [global::ProtoBuf.ProtoMember(6, Name = @"txnid_least_bits_of_low_watermark")]
+    public ulong TxnidLeastBitsOfLowWatermark
+    {
+        get => __pbn__TxnidLeastBitsOfLowWatermark.GetValueOrDefault();
+        set => __pbn__TxnidLeastBitsOfLowWatermark = value;
+    }
+
+    public bool ShouldSerializeTxnidLeastBitsOfLowWatermark() => __pbn__TxnidLeastBitsOfLowWatermark != null;
+    public void ResetTxnidLeastBitsOfLowWatermark() => __pbn__TxnidLeastBitsOfLowWatermark = null;
+    private ulong? __pbn__TxnidLeastBitsOfLowWatermark;
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2791,6 +3356,7 @@
         get => __pbn__TxnidLeastBits ?? 0;
         set => __pbn__TxnidLeastBits = value;
     }
+
     public bool ShouldSerializeTxnidLeastBits() => __pbn__TxnidLeastBits != null;
     public void ResetTxnidLeastBits() => __pbn__TxnidLeastBits = null;
     private ulong? __pbn__TxnidLeastBits;
@@ -2802,6 +3368,7 @@
         get => __pbn__TxnidMostBits ?? 0;
         set => __pbn__TxnidMostBits = value;
     }
+
     public bool ShouldSerializeTxnidMostBits() => __pbn__TxnidMostBits != null;
     public void ResetTxnidMostBits() => __pbn__TxnidMostBits = null;
     private ulong? __pbn__TxnidMostBits;
@@ -2813,6 +3380,7 @@
         get => __pbn__Error ?? ServerError.UnknownError;
         set => __pbn__Error = value;
     }
+
     public bool ShouldSerializeError() => __pbn__Error != null;
     public void ResetError() => __pbn__Error = null;
     private ServerError? __pbn__Error;
@@ -2824,10 +3392,10 @@
         get => __pbn__Message ?? "";
         set => __pbn__Message = value;
     }
+
     public bool ShouldSerializeMessage() => __pbn__Message != null;
     public void ResetMessage() => __pbn__Message = null;
     private string __pbn__Message;
-
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -2910,10 +3478,10 @@
     public CommandLookupTopicResponse LookupTopicResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(25)]
-    public CommandConsumerStats ConsumerStats { get; set; }
+    public CommandConsumerStats consumerStats { get; set; }
 
     [global::ProtoBuf.ProtoMember(26)]
-    public CommandConsumerStatsResponse ConsumerStatsResponse { get; set; }
+    public CommandConsumerStatsResponse consumerStatsResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(27)]
     public CommandReachedEndOfTopic ReachedEndOfTopic { get; set; }
@@ -2931,25 +3499,25 @@
     public CommandActiveConsumerChange ActiveConsumerChange { get; set; }
 
     [global::ProtoBuf.ProtoMember(32)]
-    public CommandGetTopicsOfNamespace GetTopicsOfNamespace { get; set; }
+    public CommandGetTopicsOfNamespace getTopicsOfNamespace { get; set; }
 
     [global::ProtoBuf.ProtoMember(33)]
-    public CommandGetTopicsOfNamespaceResponse GetTopicsOfNamespaceResponse { get; set; }
+    public CommandGetTopicsOfNamespaceResponse getTopicsOfNamespaceResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(34)]
-    public CommandGetSchema GetSchema { get; set; }
+    public CommandGetSchema getSchema { get; set; }
 
     [global::ProtoBuf.ProtoMember(35)]
-    public CommandGetSchemaResponse GetSchemaResponse { get; set; }
+    public CommandGetSchemaResponse getSchemaResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(36)]
-    public CommandAuthChallenge AuthChallenge { get; set; }
+    public CommandAuthChallenge authChallenge { get; set; }
 
     [global::ProtoBuf.ProtoMember(37)]
     public CommandAuthResponse AuthResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(38)]
-    public CommandAckResponse AckResponse { get; set; }
+    public CommandAckResponse ackResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(39)]
     public CommandGetOrCreateSchema GetOrCreateSchema { get; set; }
@@ -2958,148 +3526,239 @@
     public CommandGetOrCreateSchemaResponse GetOrCreateSchemaResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(50)]
-    public CommandNewTxn NewTxn { get; set; }
+    public CommandNewTxn newTxn { get; set; }
 
     [global::ProtoBuf.ProtoMember(51)]
-    public CommandNewTxnResponse NewTxnResponse { get; set; }
+    public CommandNewTxnResponse newTxnResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(52)]
-    public CommandAddPartitionToTxn AddPartitionToTxn { get; set; }
+    public CommandAddPartitionToTxn addPartitionToTxn { get; set; }
 
     [global::ProtoBuf.ProtoMember(53)]
-    public CommandAddPartitionToTxnResponse AddPartitionToTxnResponse { get; set; }
+    public CommandAddPartitionToTxnResponse addPartitionToTxnResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(54)]
-    public CommandAddSubscriptionToTxn AddSubscriptionToTxn { get; set; }
+    public CommandAddSubscriptionToTxn addSubscriptionToTxn { get; set; }
 
     [global::ProtoBuf.ProtoMember(55)]
-    public CommandAddSubscriptionToTxnResponse AddSubscriptionToTxnResponse { get; set; }
+    public CommandAddSubscriptionToTxnResponse addSubscriptionToTxnResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(56)]
-    public CommandEndTxn EndTxn { get; set; }
+    public CommandEndTxn endTxn { get; set; }
 
     [global::ProtoBuf.ProtoMember(57)]
-    public CommandEndTxnResponse EndTxnResponse { get; set; }
+    public CommandEndTxnResponse endTxnResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(58)]
-    public CommandEndTxnOnPartition EndTxnOnPartition { get; set; }
+    public CommandEndTxnOnPartition endTxnOnPartition { get; set; }
 
     [global::ProtoBuf.ProtoMember(59)]
-    public CommandEndTxnOnPartitionResponse EndTxnOnPartitionResponse { get; set; }
+    public CommandEndTxnOnPartitionResponse endTxnOnPartitionResponse { get; set; }
 
     [global::ProtoBuf.ProtoMember(60)]
-    public CommandEndTxnOnSubscription EndTxnOnSubscription { get; set; }
+    public CommandEndTxnOnSubscription endTxnOnSubscription { get; set; }
 
     [global::ProtoBuf.ProtoMember(61)]
-    public CommandEndTxnOnSubscriptionResponse EndTxnOnSubscriptionResponse { get; set; }
+    public CommandEndTxnOnSubscriptionResponse endTxnOnSubscriptionResponse { get; set; }
+
+    [global::ProtoBuf.ProtoMember(62)]
+    public CommandTcClientConnectRequest tcClientConnectRequest { get; set; }
+
+    [global::ProtoBuf.ProtoMember(63)]
+    public CommandTcClientConnectResponse tcClientConnectResponse { get; set; }
+
+    [global::ProtoBuf.ProtoMember(64)]
+    public CommandWatchTopicList watchTopicList { get; set; }
+
+    [global::ProtoBuf.ProtoMember(65)]
+    public CommandWatchTopicListSuccess watchTopicListSuccess { get; set; }
+
+    [global::ProtoBuf.ProtoMember(66)]
+    public CommandWatchTopicUpdate watchTopicUpdate { get; set; }
+
+    [global::ProtoBuf.ProtoMember(67)]
+    public CommandWatchTopicListClose watchTopicListClose { get; set; }
+
+    [global::ProtoBuf.ProtoMember(68)]
+    public CommandTopicMigrated topicMigrated { get; set; }
 
     [global::ProtoBuf.ProtoContract()]
     public enum Type
     {
         [global::ProtoBuf.ProtoEnum(Name = @"CONNECT")]
         Connect = 2,
+
         [global::ProtoBuf.ProtoEnum(Name = @"CONNECTED")]
         Connected = 3,
+
         [global::ProtoBuf.ProtoEnum(Name = @"SUBSCRIBE")]
         Subscribe = 4,
+
         [global::ProtoBuf.ProtoEnum(Name = @"PRODUCER")]
         Producer = 5,
+
         [global::ProtoBuf.ProtoEnum(Name = @"SEND")]
         Send = 6,
+
         [global::ProtoBuf.ProtoEnum(Name = @"SEND_RECEIPT")]
         SendReceipt = 7,
+
         [global::ProtoBuf.ProtoEnum(Name = @"SEND_ERROR")]
         SendError = 8,
+
         [global::ProtoBuf.ProtoEnum(Name = @"MESSAGE")]
         Message = 9,
+
         [global::ProtoBuf.ProtoEnum(Name = @"ACK")]
         Ack = 10,
+
         [global::ProtoBuf.ProtoEnum(Name = @"FLOW")]
         Flow = 11,
+
         [global::ProtoBuf.ProtoEnum(Name = @"UNSUBSCRIBE")]
         Unsubscribe = 12,
+
         [global::ProtoBuf.ProtoEnum(Name = @"SUCCESS")]
         Success = 13,
+
         [global::ProtoBuf.ProtoEnum(Name = @"ERROR")]
         Error = 14,
+
         [global::ProtoBuf.ProtoEnum(Name = @"CLOSE_PRODUCER")]
         CloseProducer = 15,
+
         [global::ProtoBuf.ProtoEnum(Name = @"CLOSE_CONSUMER")]
         CloseConsumer = 16,
+
         [global::ProtoBuf.ProtoEnum(Name = @"PRODUCER_SUCCESS")]
         ProducerSuccess = 17,
+
         [global::ProtoBuf.ProtoEnum(Name = @"PING")]
         Ping = 18,
+
         [global::ProtoBuf.ProtoEnum(Name = @"PONG")]
         Pong = 19,
+
         [global::ProtoBuf.ProtoEnum(Name = @"REDELIVER_UNACKNOWLEDGED_MESSAGES")]
         RedeliverUnacknowledgedMessages = 20,
+
         [global::ProtoBuf.ProtoEnum(Name = @"PARTITIONED_METADATA")]
         PartitionedMetadata = 21,
+
         [global::ProtoBuf.ProtoEnum(Name = @"PARTITIONED_METADATA_RESPONSE")]
         PartitionedMetadataResponse = 22,
+
         [global::ProtoBuf.ProtoEnum(Name = @"LOOKUP")]
         Lookup = 23,
+
         [global::ProtoBuf.ProtoEnum(Name = @"LOOKUP_RESPONSE")]
         LookupResponse = 24,
+
         [global::ProtoBuf.ProtoEnum(Name = @"CONSUMER_STATS")]
         ConsumerStats = 25,
+
         [global::ProtoBuf.ProtoEnum(Name = @"CONSUMER_STATS_RESPONSE")]
         ConsumerStatsResponse = 26,
+
         [global::ProtoBuf.ProtoEnum(Name = @"REACHED_END_OF_TOPIC")]
         ReachedEndOfTopic = 27,
+
         [global::ProtoBuf.ProtoEnum(Name = @"SEEK")]
         Seek = 28,
+
         [global::ProtoBuf.ProtoEnum(Name = @"GET_LAST_MESSAGE_ID")]
         GetLastMessageId = 29,
+
         [global::ProtoBuf.ProtoEnum(Name = @"GET_LAST_MESSAGE_ID_RESPONSE")]
         GetLastMessageIdResponse = 30,
+
         [global::ProtoBuf.ProtoEnum(Name = @"ACTIVE_CONSUMER_CHANGE")]
         ActiveConsumerChange = 31,
+
         [global::ProtoBuf.ProtoEnum(Name = @"GET_TOPICS_OF_NAMESPACE")]
         GetTopicsOfNamespace = 32,
+
         [global::ProtoBuf.ProtoEnum(Name = @"GET_TOPICS_OF_NAMESPACE_RESPONSE")]
         GetTopicsOfNamespaceResponse = 33,
+
         [global::ProtoBuf.ProtoEnum(Name = @"GET_SCHEMA")]
         GetSchema = 34,
+
         [global::ProtoBuf.ProtoEnum(Name = @"GET_SCHEMA_RESPONSE")]
         GetSchemaResponse = 35,
+
         [global::ProtoBuf.ProtoEnum(Name = @"AUTH_CHALLENGE")]
         AuthChallenge = 36,
+
         [global::ProtoBuf.ProtoEnum(Name = @"AUTH_RESPONSE")]
         AuthResponse = 37,
+
         [global::ProtoBuf.ProtoEnum(Name = @"ACK_RESPONSE")]
         AckResponse = 38,
+
         [global::ProtoBuf.ProtoEnum(Name = @"GET_OR_CREATE_SCHEMA")]
         GetOrCreateSchema = 39,
+
         [global::ProtoBuf.ProtoEnum(Name = @"GET_OR_CREATE_SCHEMA_RESPONSE")]
         GetOrCreateSchemaResponse = 40,
+
         [global::ProtoBuf.ProtoEnum(Name = @"NEW_TXN")]
         NewTxn = 50,
+
         [global::ProtoBuf.ProtoEnum(Name = @"NEW_TXN_RESPONSE")]
         NewTxnResponse = 51,
+
         [global::ProtoBuf.ProtoEnum(Name = @"ADD_PARTITION_TO_TXN")]
         AddPartitionToTxn = 52,
+
         [global::ProtoBuf.ProtoEnum(Name = @"ADD_PARTITION_TO_TXN_RESPONSE")]
         AddPartitionToTxnResponse = 53,
+
         [global::ProtoBuf.ProtoEnum(Name = @"ADD_SUBSCRIPTION_TO_TXN")]
         AddSubscriptionToTxn = 54,
+
         [global::ProtoBuf.ProtoEnum(Name = @"ADD_SUBSCRIPTION_TO_TXN_RESPONSE")]
         AddSubscriptionToTxnResponse = 55,
+
         [global::ProtoBuf.ProtoEnum(Name = @"END_TXN")]
         EndTxn = 56,
+
         [global::ProtoBuf.ProtoEnum(Name = @"END_TXN_RESPONSE")]
         EndTxnResponse = 57,
+
         [global::ProtoBuf.ProtoEnum(Name = @"END_TXN_ON_PARTITION")]
         EndTxnOnPartition = 58,
+
         [global::ProtoBuf.ProtoEnum(Name = @"END_TXN_ON_PARTITION_RESPONSE")]
         EndTxnOnPartitionResponse = 59,
+
         [global::ProtoBuf.ProtoEnum(Name = @"END_TXN_ON_SUBSCRIPTION")]
         EndTxnOnSubscription = 60,
+
         [global::ProtoBuf.ProtoEnum(Name = @"END_TXN_ON_SUBSCRIPTION_RESPONSE")]
         EndTxnOnSubscriptionResponse = 61,
-    }
 
+        [global::ProtoBuf.ProtoEnum(Name = @"TC_CLIENT_CONNECT_REQUEST")]
+        TcClientConnectRequest = 62,
+
+        [global::ProtoBuf.ProtoEnum(Name = @"TC_CLIENT_CONNECT_RESPONSE")]
+        TcClientConnectResponse = 63,
+
+        [global::ProtoBuf.ProtoEnum(Name = @"WATCH_TOPIC_LIST")]
+        WatchTopicList = 64,
+
+        [global::ProtoBuf.ProtoEnum(Name = @"WATCH_TOPIC_LIST_SUCCESS")]
+        WatchTopicListSuccess = 65,
+
+        [global::ProtoBuf.ProtoEnum(Name = @"WATCH_TOPIC_UPDATE")]
+        WatchTopicUpdate = 66,
+
+        [global::ProtoBuf.ProtoEnum(Name = @"WATCH_TOPIC_LIST_CLOSE")]
+        WatchTopicListClose = 67,
+
+        [global::ProtoBuf.ProtoEnum(Name = @"TOPIC_MIGRATED")]
+        TopicMigrated = 68,
+    }
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -3107,17 +3766,30 @@
 {
     [global::ProtoBuf.ProtoEnum(Name = @"NONE")]
     None = 0,
+
     [global::ProtoBuf.ProtoEnum(Name = @"LZ4")]
     Lz4 = 1,
+
     [global::ProtoBuf.ProtoEnum(Name = @"ZLIB")]
     Zlib = 2,
+
     [global::ProtoBuf.ProtoEnum(Name = @"ZSTD")]
     Zstd = 3,
+
     [global::ProtoBuf.ProtoEnum(Name = @"SNAPPY")]
     Snappy = 4,
 }
 
 [global::ProtoBuf.ProtoContract()]
+public enum ProducerAccessMode
+{
+    Shared = 0,
+    Exclusive = 1,
+    WaitForExclusive = 2,
+    ExclusiveWithFencing = 3,
+}
+
+[global::ProtoBuf.ProtoContract()]
 public enum ServerError
 {
     UnknownError = 0,
@@ -3144,6 +3816,8 @@
     InvalidTxnStatus = 21,
     NotAllowedError = 22,
     TransactionConflict = 23,
+    TransactionNotFound = 24,
+    ProducerFenced = 25,
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -3159,36 +3833,66 @@
 {
     [global::ProtoBuf.ProtoEnum(Name = @"v0")]
     V0 = 0,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v1")]
     V1 = 1,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v2")]
     V2 = 2,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v3")]
     V3 = 3,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v4")]
     V4 = 4,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v5")]
     V5 = 5,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v6")]
     V6 = 6,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v7")]
     V7 = 7,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v8")]
     V8 = 8,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v9")]
     V9 = 9,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v10")]
     V10 = 10,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v11")]
     V11 = 11,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v12")]
     V12 = 12,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v13")]
     V13 = 13,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v14")]
     V14 = 14,
+
     [global::ProtoBuf.ProtoEnum(Name = @"v15")]
     V15 = 15,
+
+    [global::ProtoBuf.ProtoEnum(Name = @"v16")]
+    V16 = 16,
+
+    [global::ProtoBuf.ProtoEnum(Name = @"v17")]
+    V17 = 17,
+
+    [global::ProtoBuf.ProtoEnum(Name = @"v18")]
+    V18 = 18,
+
+    [global::ProtoBuf.ProtoEnum(Name = @"v19")]
+    V19 = 19,
+
+    [global::ProtoBuf.ProtoEnum(Name = @"v20")]
+    V20 = 20,
 }
 
 [global::ProtoBuf.ProtoContract()]
@@ -3196,6 +3900,7 @@
 {
     [global::ProtoBuf.ProtoEnum(Name = @"AUTO_SPLIT")]
     AutoSplit = 0,
+
     [global::ProtoBuf.ProtoEnum(Name = @"STICKY")]
     Sticky = 1,
 }
@@ -3205,10 +3910,13 @@
 {
     [global::ProtoBuf.ProtoEnum(Name = @"COMMIT")]
     Commit = 0,
+
     [global::ProtoBuf.ProtoEnum(Name = @"ABORT")]
     Abort = 1,
 }
 
 #pragma warning restore CS0612, CS0618, CS1591, CS3021, IDE0079, IDE1006, RCS1036, RCS1057, RCS1085, RCS1192
+
 #endregion
+
 #nullable restore
commit	6c52a27a4cf1f735a8653948bd3bdd3b8212e344	[log] [tgz]
author	entvex <entvex@users.noreply.github.com>	Thu Nov 24 10:55:05 2022 +0100
committer	GitHub <noreply@github.com>	Thu Nov 24 10:55:05 2022 +0100
tree	8af61b4fbfa2dc7a7a1f283b74af8ba546aa7a7f
parent	9328efa93e9933f6758dbda7a0145fe02e24a229 [diff]