[
https://issues.apache.org/jira/browse/KAFKA-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346678#comment-15346678
]
Elias Levy commented on KAFKA-2359:
-----------------------------------
I wonder if the calling pause() before calling poll() and seekToBeging() or
seekToEnd() will solve your problem. The pause should stop the fetching of
records, while the poll() triggers the interaction with the coordinator to
perform the partition assignment before calling seekToBegining and seekToEnd.
> New consumer - partitions auto assigned only on poll
> ----------------------------------------------------
>
> Key: KAFKA-2359
> URL: https://issues.apache.org/jira/browse/KAFKA-2359
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.9.0.0
> Reporter: Stevo Slavic
> Priority: Minor
>
> In the new consumer I encountered unexpected behavior. After constructing
> {{KafkaConsumer}} instance with configured consumer rebalance callback
> handler, and subscribing to a topic with "consumer.subscribe(topic)",
> retrieving subscriptions would return empty set and callback handler would
> not get called (no partitions ever assigned or revoked), no matter how long
> instance was up.
> Then I found by inspecting {{KafkaConsumer}} code that partition assignment
> will only be triggered on first {{poll}}, since {{pollOnce}} has:
> {noformat}
> // ensure we have partitions assigned if we expect to
> if (subscriptions.partitionsAutoAssigned())
> coordinator.ensurePartitionAssignment();
> {noformat}
> I'm proposing to fix this by including same {{ensurePartitionAssignment}}
> fragment in {{KafkaConsumer.subscriptions}} accessor as well.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
