Stevo Slavic created KAFKA-2359:
-----------------------------------
Summary: 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.8.3
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)
