(kafka) branch trunk updated: MINOR: reduce per-batch logging to TRACE level (#19101)

[jo...@apache.org]

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

jolshan 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 d85946da19b MINOR: reduce per-batch logging to TRACE level (#19101)
d85946da19b is described below

commit d85946da19bb2c12f861348193ac89c839cd8bb7
Author: Matthias J. Sax <ma...@confluent.io>
AuthorDate: Thu Mar 6 11:06:26 2025 -0800

    MINOR: reduce per-batch logging to TRACE level (#19101)
    
    Logging on a per-batch bases is very chatty, and should only be done at
    TRACE level to avoid spamming DEBUG logs.
    
    Reviewers: Justine Olshan <jo...@confluent.io>, Lucas Brutschy <lb...@confluent.io>
---
 .../org/apache/kafka/clients/producer/internals/TransactionManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java b/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
index af115660284..c78134c72ec 100644
--- a/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
+++ b/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
@@ -704,7 +704,7 @@ public class TransactionManager {
 
     public synchronized void handleCompletedBatch(ProducerBatch batch, ProduceResponse.PartitionResponse response) {
         int lastAckedSequence = maybeUpdateLastAckedSequence(batch.topicPartition, batch.lastSequence());
-        log.debug("ProducerId: {}; Set last ack'd sequence number for topic-partition {} to {}",
+        log.trace("ProducerId: {}; Set last ack'd sequence number for topic-partition {} to {}",
                 batch.producerId(),
                 batch.topicPartition,
                 lastAckedSequence);