[kafka] branch 2.8 updated: KAFKA-13037: "Thread state is already PENDING_SHUTDOWN" log spam

[ab...@apache.org]

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

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


The following commit(s) were added to refs/heads/2.8 by this push:
     new 75ae1a8  KAFKA-13037: "Thread state is already PENDING_SHUTDOWN" log spam
75ae1a8 is described below

commit 75ae1a8c5aef96b830c64a1d11d5d7c4ee2ac197
Author: John Gray <16...@users.noreply.github.com>
AuthorDate: Wed Jul 14 00:00:23 2021 -0400

    KAFKA-13037: "Thread state is already PENDING_SHUTDOWN" log spam
    
    Demote this from INFO to debug since it's absolutely spamming the logs
    
    Reviewers: Anna Sophie Blee-Goldman <ab...@apache.org>
---
 .../java/org/apache/kafka/streams/processor/internals/StreamThread.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
index 3286b3b..dbe7e98 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
@@ -724,7 +724,7 @@ public class StreamThread extends Thread {
         // Should only proceed when the thread is still running after #pollRequests(), because no external state mutation
         // could affect the task manager state beyond this point within #runOnce().
         if (!isRunning()) {
-            log.info("Thread state is already {}, skipping the run once call after poll request", state);
+            log.debug("Thread state is already {}, skipping the run once call after poll request", state);
             return;
         }