kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Larry McQueary (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-6764) ConsoleConsumer behavior inconsistent when specifying --partition --from-beginning
Date Sun, 08 Apr 2018 04:08:00 GMT
Larry McQueary created KAFKA-6764:

             Summary: ConsoleConsumer behavior inconsistent when specifying --partition --from-beginning

                 Key: KAFKA-6764
                 URL: https://issues.apache.org/jira/browse/KAFKA-6764
             Project: Kafka
          Issue Type: Bug
          Components: consumer
            Reporter: Larry McQueary

Per its usage statement, {{kafka-console-consumer.sh}} ignores {{\-\-from-beginning}} when
the specified consumer group has committed offsets, and sets {{auto.offset.reset}} to {{latest}}.
However, if {{\-\-partition}} is also specified, {{\-\-from-beginning}} is observed in all
cases, whether there are committed offsets or not.

This happens because when {{\-\-from-beginning}} is specified, {{offsetArg}} is set to {{OffsetRequest.EarliestTime}}.
However, {{offsetArg}} is [only passed to the constructor|https://github.com/apache/kafka/blob/fedac0cea74feeeece529ee1c0cefd6af53ecbdd/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L76-L79]
for {{NewShinyConsumer}} when {{\-\-partition}} is also specified.

This case should either be handled consistently, or the usage statement should be modified
to indicate the actual behavior/usage. 

This message was sent by Atlassian JIRA

View raw message