[
https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336648#comment-17336648
]
Flink Jira Bot commented on FLINK-8895:
---
This issue was labeled "stale-major" 7 ago and has not
[
https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17328654#comment-17328654
]
Flink Jira Bot commented on FLINK-8895:
---
This major issue is unassigned and itself and all of its
[
https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16395106#comment-16395106
]
Stephan Ewen commented on FLINK-8895:
-
I think you don't need to add filtering code or anything, all
[
https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16393973#comment-16393973
]
godfrey johnson commented on FLINK-8895:
[~StephanEwen] After the partition leader is changed, the
[
https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391186#comment-16391186
]
Stephan Ewen commented on FLINK-8895:
-
I don't think we need to do anything special here. It should be
[
https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391079#comment-16391079
]
godfrey johnson commented on FLINK-8895:
[~StephanEwen] It's a good way to addÂ
[
https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391039#comment-16391039
]
Stephan Ewen commented on FLINK-8895:
-
The Kafka Consumer 0.8 connects to new brokers on exceptions
