From b169df1a07348ac86c4be7db731302ef70b0a651 Mon Sep 17 00:00:00 2001 From: Nikolay Perfilov Date: Thu, 23 Jan 2025 16:09:05 +0300 Subject: [PATCH] Fix after rebase --- topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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); }