(kafka) branch trunk updated: MINOR: fix warn log message in Kafka Streams (#18878)

[mjsax]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 9fbf14d5449 MINOR: fix warn log message in Kafka Streams (#18878)
9fbf14d5449 is described below

commit 9fbf14d5449f17cfb709abadd36f8278e4471af6
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Thu Feb 13 09:30:07 2025 -0800

    MINOR: fix warn log message in Kafka Streams (#18878)
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>, Bill Bejeck 
<b...@confluent.io>
---
 .../java/org/apache/kafka/streams/processor/internals/StreamTask.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
index b612223197e..424d6f7af61 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
@@ -1024,7 +1024,7 @@ public class StreamTask extends AbstractTask implements 
ProcessorNodePunctuator,
             log.warn(
                 "Encountered {} while trying to fetch committed offsets, will 
retry initializing the metadata in the next loop." +
                     "\nConsider overwriting consumer config {} to a larger 
value to avoid timeout errors",
-                time.toString(),
+                timeoutException.toString(),
                 ConsumerConfig.DEFAULT_API_TIMEOUT_MS_CONFIG);
 
             // re-throw to trigger `task.timeout.ms`