kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: KAFKA-5468: WorkerSourceTask offset commit loglevel changes
Date Fri, 21 Jul 2017 04:55:54 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk cd207dd3f -> ad6c53d89


KAFKA-5468: WorkerSourceTask offset commit loglevel changes

changed log level for source connector worker task when committing offsets

Author: Stephane Maarek <stephane@simplemachines.com.au>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #3367 from simplesteph/KAFKA-5468


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ad6c53d8
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ad6c53d8
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ad6c53d8

Branch: refs/heads/trunk
Commit: ad6c53d89e5dac2e6d3fa9e3df9c597d0d52e485
Parents: cd207dd
Author: Stephane Maarek <stephane@simplemachines.com.au>
Authored: Thu Jul 20 21:55:50 2017 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Thu Jul 20 21:55:50 2017 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/connect/runtime/WorkerSourceTask.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/ad6c53d8/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java
----------------------------------------------------------------------
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 5627145..e676d50 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
@@ -281,7 +281,7 @@ class WorkerSourceTask extends WorkerTask {
     public boolean commitOffsets() {
         long commitTimeoutMs = workerConfig.getLong(WorkerConfig.OFFSET_COMMIT_TIMEOUT_MS_CONFIG);
 
-        log.debug("{} Committing offsets", this);
+        log.info("{} Committing offsets", this);
 
         long started = time.milliseconds();
         long timeout = started + commitTimeoutMs;
@@ -298,7 +298,7 @@ class WorkerSourceTask extends WorkerTask {
             // to persistent storage
 
             // Next we need to wait for all outstanding messages to finish sending
-            log.debug("{} flushing {} outstanding messages for offset commit", this, outstandingMessages.size());
+            log.info("{} flushing {} outstanding messages for offset commit", this, outstandingMessages.size());
             while (!outstandingMessages.isEmpty()) {
                 try {
                     long timeoutMs = timeout - time.milliseconds();


Mime
View raw message