[jira] [Resolved] (KAFKA-2343) Clarify KafkaConsumer.poll rebalance behavior

["Manikumar (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Manikumar resolved KAFKA-2343.
------------------------------
    Resolution: Fixed

Javadocs updated in newer versions.

> Clarify KafkaConsumer.poll rebalance behavior
> ---------------------------------------------
>
>                 Key: KAFKA-2343
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2343
>             Project: Kafka
>          Issue Type: Bug
>          Components: consumer
>            Reporter: Jason Gustafson
>
> The current javadoc for KafkaConsumer.poll says the following:
> {code}
>      * 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.
> {code}
> 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.4.14#64029)