You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2022/02/17 01:53:51 UTC
[kafka] branch trunk updated: KAFKA-13669; Demote empty offset commit messages for source tasks to DEBUG level (#11770)
This is an automated email from the ASF dual-hosted git repository.
jgus 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 c7586cc KAFKA-13669; Demote empty offset commit messages for source tasks to DEBUG level (#11770)
c7586cc is described below
commit c7586cc38dc1844dbef0f2b0ab511b60aaef684e
Author: Chris Egerton <fe...@gmail.com>
AuthorDate: Wed Feb 16 20:50:58 2022 -0500
KAFKA-13669; Demote empty offset commit messages for source tasks to DEBUG level (#11770)
Lower the log level of a message in `WorkerSourceTask` which indicates that no messages have been produced by the task since it is spammy and causing users confusion.
Reviewers: Jason Gustafson <ja...@confluent.io>
---
.../main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
index b036396..9ce2b8d 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
@@ -491,7 +491,7 @@ class WorkerSourceTask extends WorkerTask {
}
if (committableOffsets.isEmpty()) {
- log.info("{} Either no records were produced by the task since the last offset commit, "
+ log.debug("{} Either no records were produced by the task since the last offset commit, "
+ "or every record has been filtered out by a transformation "
+ "or dropped due to transformation or conversion errors.",
this