(kafka) branch 3.7 updated: KAFKA-16159: MINOR - Correcting logs to debug telemetry reporter (#15228)

[mjsax]

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

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


The following commit(s) were added to refs/heads/3.7 by this push:
     new 43c6064367b KAFKA-16159: MINOR - Correcting logs to debug telemetry 
reporter (#15228)
43c6064367b is described below

commit 43c6064367be4f2bb31dc31db908f48ca16cb939
Author: Apoorv Mittal <amit...@confluent.io>
AuthorDate: Fri Jan 19 07:30:09 2024 +0530

    KAFKA-16159: MINOR - Correcting logs to debug telemetry reporter (#15228)
    
    Removed debug log as next time to update runs in poll loop and excessive 
logging happens.
    
    Reviewers: Qichao Chu <qic...@uber.com>, Philip Nee <p...@confluent.io>, 
Matthias J. Sax <matth...@confluent.io>
---
 .../kafka/common/telemetry/internals/ClientTelemetryReporter.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java
 
b/clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java
index 959cec107db..722280e9cbc 100644
--- 
a/clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java
+++ 
b/clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java
@@ -363,7 +363,7 @@ public class ClientTelemetryReporter implements 
MetricsReporter {
                     throw new IllegalStateException("Unknown telemetry state: 
" + localState);
             }
 
-            log.debug("For telemetry state {}, returning the value {} ms; {}", 
localState, timeMs, msg);
+            log.trace("For telemetry state {}, returning the value {} ms; {}", 
localState, timeMs, msg);
             return timeMs;
         }
 
@@ -640,6 +640,7 @@ public class ClientTelemetryReporter implements 
MetricsReporter {
              signal to the broker that we need to have a client instance ID 
assigned.
             */
             Uuid clientInstanceId = (localSubscription != null) ? 
localSubscription.clientInstanceId() : Uuid.ZERO_UUID;
+            log.debug("Creating telemetry subscription request with client 
instance id {}", clientInstanceId);
 
             lock.writeLock().lock();
             try {
@@ -668,6 +669,7 @@ public class ClientTelemetryReporter implements 
MetricsReporter {
                 return Optional.empty();
             }
 
+            log.debug("Creating telemetry push request with client instance id 
{}", localSubscription.clientInstanceId());
             /*
              Don't send a push request if we don't have the collector 
initialized. Re-attempt
              the push on the next interval.