(kafka) branch 4.2 updated: MINOR: improve logging (#21147)

[mjsax]

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

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


The following commit(s) were added to refs/heads/4.2 by this push:
     new fbf8637b11a MINOR: improve logging (#21147)
fbf8637b11a is described below

commit fbf8637b11a7b994fd22e31cf24e88af1209c8e7
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Mon Dec 15 15:00:59 2025 -0800

    MINOR: improve logging (#21147)
    
    We should not advice to increase the consumer timeout. Kafka Streams
    handles the timeout gracefully and increasing the consumer timeout
    could actually lead to longer blocking call resulting in undesired
    rebalancing.
    
    Reviewer: Lucas Brutschy <lbruts...@confluent.io>
---
 .../org/apache/kafka/streams/processor/internals/StreamTask.java  | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

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 bea998c4711..85c322f2b5f 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
@@ -17,7 +17,6 @@
 package org.apache.kafka.streams.processor.internals;
 
 import org.apache.kafka.clients.consumer.Consumer;
-import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.clients.consumer.OffsetAndMetadata;
 import org.apache.kafka.clients.producer.ProducerRecord;
@@ -1078,10 +1077,9 @@ public class StreamTask extends AbstractTask implements 
ProcessorNodePunctuator,
             );
         } catch (final TimeoutException timeoutException) {
             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",
-                timeoutException.toString(),
-                ConsumerConfig.DEFAULT_API_TIMEOUT_MS_CONFIG);
+                "Encountered {} while trying to fetch committed offsets, will 
retry initializing the metadata in the next loop.",
+                timeoutException.toString()
+            );
 
             // re-throw to trigger `task.timeout.ms`
             throw timeoutException;