Consumer Rebalance issue and follow-up on KAFKA-9752

2020-08-09 Thread Dibyendu Bhattacharya
Hi, This is regards to https://issues.apache.org/jira/browse/KAFKA-9752 issue where Consumer rebalance can be stuck after new member timeout with old JoinGroup version. We have taken the fix, but now see a different issue . Earlier the ConsumerGroup was stuck in "PendingRebalance" state , which

Kafka Simple Consumer API for 0.9

2014-11-14 Thread Dibyendu Bhattacharya
Hi, Is the Simple Consumer API will change in Kafka 0.9 ? I can see a Consumer Re-design approach for Kafka 0.9 , which I believe will not impact any client written using Simple Consumer API . Is that correct ? Regards, Dibyendu

Re: Kafka/Hadoop consumers and producers

2013-08-09 Thread dibyendu . bhattacharya
Hi Ken, I am also working on making the Camus fit for Non Avro message for our requirement. I see you mentioned about this patch (https://github.com/linkedin/camus/commit/87917a2aea46da9d21c8f67129f6463af52f7aa8) which supports custom data writer for Camus. But this patch is not pulled into

[jira] [Commented] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state

2017-04-19 Thread Dibyendu Bhattacharya (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15974338#comment-15974338 ] Dibyendu Bhattacharya commented on KAFKA-3083: -- Hi [~junrao] We also

[jira] [Created] (KAFKA-948) ISR list in LeaderAndISR path not updated for partitions when Broker (which is not leader) is down

2013-06-19 Thread Dibyendu Bhattacharya (JIRA)
Dibyendu Bhattacharya created KAFKA-948: --- Summary: ISR list in LeaderAndISR path not updated for partitions when Broker (which is not leader) is down Key: KAFKA-948 URL: https://issues.apache.org/jira

[jira] [Commented] (KAFKA-948) ISR list in LeaderAndISR path not updated for partitions when Broker (which is not leader) is down

2013-06-19 Thread Dibyendu Bhattacharya (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13688871#comment-13688871 ] Dibyendu Bhattacharya commented on KAFKA-948: - I have tested a Fix, w