[kafka] branch 2.4 updated: dont spam (#7730)

[bbejeck]

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 <sop...@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 <mj...@apache.org>, Bruno Cadonna 
<br...@confluent.io>, Bill Bejeck <bbej...@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);
             }