Fix after rebase

pnv1 · pnv1 · commit b169df1a0734 · 2025-01-23T16:09:05.000+03:00
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
@@ -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);
             }

Original file line number	Diff line number	Diff line change
`@@ -426,7 +426,7 @@ private void onInitResponse(YdbTopic.StreamWriteMessage.InitResponse response) {`
`426`	`426`	`// TODO: remember supported codecs for further validation`
`427`	`427`	`if (!sentMessages.isEmpty()) {`
`428`	`428`	`// resending messages that haven't received acks yet`
`429`		`- logger.info("[{}] Resending {} messages that haven't received ack's yet into new session...", fullId,`
	`429`	`+ logger.info("[{}] Resending {} messages that haven't received ack's yet into new session...", streamId,`
`430`	`430`	`sentMessages.size());`
`431`	`431`	`messageSender.sendMessages(sentMessages);`
`432`	`432`	`}`