diff --git a/ydb/_topic_reader/topic_reader_asyncio.py b/ydb/_topic_reader/topic_reader_asyncio.py
index 7b3d1cfa..81c6d9f4 100644
--- a/ydb/_topic_reader/topic_reader_asyncio.py
+++ b/ydb/_topic_reader/topic_reader_asyncio.py
@@ -192,7 +192,7 @@ async def _connection_loop(self):
                 if self._stream_reader is not None:
                     # noinspection PyBroadException
                     try:
-                        await self._stream_reader.close()
+                        await self._stream_reader.close(flush=False)
                     except BaseException:
                         # supress any error on close stream reader
                         pass