We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7de9687 commit a030a44Copy full SHA for a030a44
ydb/_grpc/grpcwrapper/ydb_topic.py
@@ -143,13 +143,15 @@ class CommitOffsetRequest(IToProto):
143
consumer: str
144
partition_id: int
145
offset: int
146
+ read_session_id: Optional[str] = None
147
148
def to_proto(self) -> ydb_topic_pb2.CommitOffsetRequest:
149
return ydb_topic_pb2.CommitOffsetRequest(
150
path=self.path,
151
consumer=self.consumer,
152
partition_id=self.partition_id,
153
offset=self.offset,
154
+ read_session_id=self.read_session_id,
155
)
156
157
0 commit comments