This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 4.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/4.0 by this push:
new dfbeae858fd MINOR: reduce per-batch logging to TRACE level (#19101)
dfbeae858fd is described below
commit dfbeae858fd291fd358f15ff4f65d7ccd70f9418
Author: Matthias J. Sax <[email protected]>
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 <[email protected]>, Lucas Brutschy
<[email protected]>
---
.../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);