kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbej...@apache.org
Subject [kafka] branch 2.4 updated: dont spam (#7730)
Date Wed, 27 Nov 2019 16:58:22 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/2.4 by this push:
     new 4228fe1  dont spam (#7730)
4228fe1 is described below

commit 4228fe109f39b321242ef781a25785ef5e6a93fd
Author: A. Sophie Blee-Goldman <sophie@confluent.io>
AuthorDate: Wed Nov 27 08:40:46 2019 -0800

    dont spam (#7730)
    
    This ends up spamming the logs and doesn't seem to be providing much useful information,
rather than logging the full task (which includes the entire topology description) we should
just log the task id.
    
    Reviewers: Matthias J. Sax <mjsax@apache.org>, Bruno Cadonna <bruno@confluent.io>,
Bill Bejeck <bbejeck@gmail.com>
---
 .../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 fcab9f1..ab9549d 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
@@ -302,7 +302,7 @@ public class StreamTask extends AbstractTask implements ProcessorNodePunctuator
                 final long committedTimestamp = decodeTimestamp(metadata.metadata());
                 partitionGroup.setPartitionTime(partition, committedTimestamp);
                 log.debug("A committed timestamp was detected: setting the partition time
of partition {}"
-                    + " to {} in stream task {}", partition, committedTimestamp, this);
+                    + " to {} in stream task {}", partition, committedTimestamp, id);
             } else {
                 log.debug("No committed timestamp was found in metadata for partition {}",
partition);
             }


Mime
View raw message