Browse Source

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
pull/2213/merge
Guozhang Wang 8 years ago
parent
commit
0e2c90bad9
  1. 2
      clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java

2
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 { @@ -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);
}

Loading…
Cancel
Save