CommitOffset with readsessionid

Author: vgvoleg

ydb/_grpc/grpcwrapper/ydb_topic.py

@@ -143,13 +143,15 @@ class CommitOffsetRequest(IToProto):
     consumer: str
     partition_id: int
     offset: int
+    read_session_id: Optional[str]
 
     def to_proto(self) -> ydb_topic_pb2.CommitOffsetRequest:
         return ydb_topic_pb2.CommitOffsetRequest(
             path=self.path,
             consumer=self.consumer,
             partition_id=self.partition_id,
             offset=self.offset,
+            read_session_id=self.read_session_id,
         )
 
 

ydb/topic.py

@@ -346,6 +346,7 @@ async def commit_offset(self, path: str, consumer: str, partition_id: int, offse
             consumer=consumer,
             partition_id=partition_id,
             offset=offset,
+            read_session_id=None,
         )
 
         await self._driver(
@@ -624,6 +625,7 @@ def commit_offset(self, path: str, consumer: str, partition_id: int, offset: int
             consumer=consumer,
             partition_id=partition_id,
             offset=offset,
+            read_session_id=None,
         )
 
         self._driver(