Skip to content

Commit 26edb97

Browse files
committed
Revert correct log message
1 parent a768b88 commit 26edb97

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

topic/src/main/java/tech/ydb/topic/read/impl/PartitionSessionImpl.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -346,7 +346,9 @@ private void sendDataToReadersIfNeeded() {
346346
DataReceivedEvent event = new DataReceivedEventImpl(this, messagesToRead, offsetsToCommit);
347347
if (logger.isDebugEnabled()) {
348348
logger.debug("[{}] DataReceivedEvent callback with {} message(s) (offsets {}-{}) is about " +
349-
"to be called...", fullId, messagesToRead.size(), commitFrom, commitTo);
349+
"to be called...", fullId, messagesToRead.size(),
350+
messagesToRead.get(0).getOffset(),
351+
messagesToRead.get(messagesToRead.size() - 1).getOffset());
350352
}
351353
dataEventCallback.apply(event)
352354
.whenComplete((res, th) -> {

0 commit comments

Comments
 (0)