[kafka] branch 3.0 updated: MINOR: remove unneeded comments to avoid misleading message (#11122)

[guozhang]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.0 by this push:
     new 3df29b1  MINOR: remove unneeded comments to avoid misleading message 
(#11122)
3df29b1 is described below

commit 3df29b1cdbea966704984fe04a4fed1b52128b0c
Author: Luke Chen <show...@gmail.com>
AuthorDate: Sat Jul 24 11:22:23 2021 +0800

    MINOR: remove unneeded comments to avoid misleading message (#11122)
    
    Reviewers: Guozhang Wang <wangg...@gmail.com>
---
 .../main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java  | 2 --
 1 file changed, 2 deletions(-)

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 5c5287c..5a8677a 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
@@ -928,8 +928,6 @@ public class Fetcher<K, V> implements Closeable {
         final AtomicInteger remainingResponses = new 
AtomicInteger(timestampsToSearchByNode.size());
 
         for (Map.Entry<Node, Map<TopicPartition, ListOffsetsPartition>> entry 
: timestampsToSearchByNode.entrySet()) {
-            // we skip sending the list off request only if there's already 
one with the exact
-            // requested offsets for the destination node
             RequestFuture<ListOffsetResult> future = 
sendListOffsetRequest(entry.getKey(), entry.getValue(), requireTimestamps);
             future.addListener(new RequestFutureListener<ListOffsetResult>() {
                 @Override