Hello,
I have subscribed to a kafka topic as below . I need to run some logic
only after the consumer has been assigned a partition .How ever
consumer.assignment() comes back as an empty set no matter how long I wait
. If I do not have the while loop and then do a consumer.poll() I do get
the records from the topic.Can any one tell me why this is happening ?
consumer.subscribe(topics);
consumer.
Set<TopicPartition> assigned=Collections.emptySet();
while(isAssigned)
{
assigned = consumer.assignment();
if(!assigned.isEmpty()) {
isAssigned= false;
}
}
Thanks,
Chinchu