diff --git a/topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java b/topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java index 58491839f..93c6834b9 100644 --- a/topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java +++ b/topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java @@ -259,6 +259,7 @@ private void sendReadRequest() { if (currentSizeBytesToRequest <= 0) { logger.debug("[{}] Nothing to request in DataRequest. sizeBytesToRequest == {}", fullId, currentSizeBytesToRequest); + sizeBytesToRequest.addAndGet(currentSizeBytesToRequest); return; } logger.debug("[{}] Sending DataRequest with {} bytes", fullId, currentSizeBytesToRequest);