kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Print offset and size in sendFetches
Date Tue, 16 May 2017 06:34:34 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk cacbba651 -> 0e2c90bad


MINOR: Print offset and size in sendFetches

Author: Guozhang Wang <wangguoz@gmail.com>

Reviewers: Jason Gustafson <jason@confluent.io>

Closes #3063 from guozhangwang/KMinor-more-logging-in-fetcher


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

Branch: refs/heads/trunk
Commit: 0e2c90bad934b276610fdcf027252553208099ac
Parents: cacbba6
Author: Guozhang Wang <wangguoz@gmail.com>
Authored: Mon May 15 23:34:31 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Mon May 15 23:34:31 2017 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/clients/consumer/internals/Fetcher.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/0e2c90ba/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
index e4365da..509993f 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
@@ -791,7 +791,7 @@ public class Fetcher<K, V> implements SubscriptionState.Listener,
Closeable {
 
                 long position = this.subscriptions.position(partition);
                 fetch.put(partition, new FetchRequest.PartitionData(position, FetchRequest.INVALID_LOG_START_OFFSET,
this.fetchSize));
-                log.trace("Added fetch request for partition {} at offset {} to node {}",
partition, position, node);
+                log.debug("Added fetch request for partition {} at offset {} to node {}",
partition, position, node);
             } else {
                 log.trace("Skipping fetch for partition {} because there is an in-flight
request to {}", partition, node);
             }


Mime
View raw message