Jason Gustafson created KAFKA-2343:
--------------------------------------
Summary: Clarify KafkaConsumer.poll rebalance behavior
Key: KAFKA-2343
URL: https://issues.apache.org/jira/browse/KAFKA-2343
Project: Kafka
Issue Type: Bug
Reporter: Jason Gustafson
The current javadoc for KafkaConsumer.poll says the following:
* The offset used for fetching the data is governed by whether or not
{@link #seek(TopicPartition, long)} is used.
* If {@link #seek(TopicPartition, long)} is used, it will use the
specified offsets on startup and on every
* rebalance, to consume data from that offset sequentially on every poll.
If not, it will use the last checkpointed
* offset using {@link #commit(Map, CommitType) commit(offsets, sync)} for
the subscribed list of partitions.
Unless I am misreading, this suggests that rebalance should reset to the seeked
position (if one was set). The consumer definitely doesn't do this currently,
so we should either fix the javadoc if that is not the desired behavior or fix
the code.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
