diff --git a/topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java b/topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java index 69245d89..9a52e9a9 100644 --- a/topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java +++ b/topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java @@ -426,7 +426,7 @@ private void onInitResponse(YdbTopic.StreamWriteMessage.InitResponse response) { // TODO: remember supported codecs for further validation if (!sentMessages.isEmpty()) { // resending messages that haven't received acks yet - logger.info("[{}] Resending {} messages that haven't received ack's yet into new session...", fullId, + logger.info("[{}] Resending {} messages that haven't received ack's yet into new session...", streamId, sentMessages.size()); messageSender.sendMessages(sentMessages); }