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

[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 95d164a3ae6 MINOR: improve logging (#21147)
95d164a3ae6 is described below

commit 95d164a3ae67b8d3860567528e2ba6ca0c532fa2
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;