Repository: kafka Updated Branches: refs/heads/trunk cacbba651 -> 0e2c90bad
MINOR: Print offset and size in sendFetches Author: Guozhang Wang <[email protected]> Reviewers: Jason Gustafson <[email protected]> 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 <[email protected]> Authored: Mon May 15 23:34:31 2017 -0700 Committer: Guozhang Wang <[email protected]> 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); }
