[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15174258#comment-15174258 ] Stephan Ewen commented on FLINK-3368: - One thing that you can try is to us the 1.0-RC3

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15174251#comment-15174251 ] Stephan Ewen commented on FLINK-3368: - In Flink 1.0, that is pretty much how it works: If brokers

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15174151#comment-15174151 ] Nick Dimiduk commented on FLINK-3368: - Kafka rebalances and the flink job must "go into recovery"?

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173899#comment-15173899 ] Stephan Ewen commented on FLINK-3368: - It has not yet been backported to the 0.10 branch, as far as I

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15154902#comment-15154902 ] ASF GitHub Bot commented on FLINK-3368: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15154632#comment-15154632 ] ASF GitHub Bot commented on FLINK-3368: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15154633#comment-15154633 ] ASF GitHub Bot commented on FLINK-3368: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15154178#comment-15154178 ] ASF GitHub Bot commented on FLINK-3368: --- Github user rmetzger commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153404#comment-15153404 ] ASF GitHub Bot commented on FLINK-3368: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153038#comment-15153038 ] ASF GitHub Bot commented on FLINK-3368: --- Github user rmetzger commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153031#comment-15153031 ] ASF GitHub Bot commented on FLINK-3368: --- GitHub user StephanEwen opened a pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153034#comment-15153034 ] ASF GitHub Bot commented on FLINK-3368: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15153030#comment-15153030 ] ASF GitHub Bot commented on FLINK-3368: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15152393#comment-15152393 ] ASF GitHub Bot commented on FLINK-3368: --- Github user rmetzger commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15152351#comment-15152351 ] ASF GitHub Bot commented on FLINK-3368: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15151290#comment-15151290 ] ASF GitHub Bot commented on FLINK-3368: --- Github user rmetzger commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15150803#comment-15150803 ] ASF GitHub Bot commented on FLINK-3368: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15150660#comment-15150660 ] ASF GitHub Bot commented on FLINK-3368: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15150659#comment-15150659 ] ASF GitHub Bot commented on FLINK-3368: --- Github user rmetzger commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15150652#comment-15150652 ] ASF GitHub Bot commented on FLINK-3368: --- Github user gyfora commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15144544#comment-15144544 ] ASF GitHub Bot commented on FLINK-3368: --- Github user rmetzger commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15144906#comment-15144906 ] ASF GitHub Bot commented on FLINK-3368: --- Github user ndimiduk commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15143862#comment-15143862 ] ASF GitHub Bot commented on FLINK-3368: --- Github user ndimiduk commented on the pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15143135#comment-15143135 ] ASF GitHub Bot commented on FLINK-3368: --- GitHub user rmetzger opened a pull request:

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15140540#comment-15140540 ] Robert Metzger commented on FLINK-3368: --- Flink's mechanism to detect the leading brokers and the

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15140731#comment-15140731 ] Gyula Fora commented on FLINK-3368: --- Thanks Robert for the detailed explanation. It sucks that they did

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137138#comment-15137138 ] Stephan Ewen commented on FLINK-3368: - I think this is a blocker > Kafka 0.8 consumer fails to

[jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns

[ https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137767#comment-15137767 ] Robert Metzger commented on FLINK-3368: --- It seems that the issue depends on the number of partitions