[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488737#comment-16488737 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on a diff

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488735#comment-16488735 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on a diff

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488710#comment-16488710 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on a diff

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488707#comment-16488707 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on a diff

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16486874#comment-16486874 ] ASF GitHub Bot commented on FLINK-9303: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16486872#comment-16486872 ] ASF GitHub Bot commented on FLINK-9303: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16486873#comment-16486873 ] ASF GitHub Bot commented on FLINK-9303: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16483847#comment-16483847 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on the iss

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16477294#comment-16477294 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on a diff

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16477171#comment-16477171 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on a diff

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16472108#comment-16472108 ] ASF GitHub Bot commented on FLINK-9303: --- Github user tedyu commented on a diff in th

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16472107#comment-16472107 ] ASF GitHub Bot commented on FLINK-9303: --- Github user tedyu commented on a diff in th

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16472106#comment-16472106 ] ASF GitHub Bot commented on FLINK-9303: --- Github user tedyu commented on a diff in th

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16471915#comment-16471915 ] ASF GitHub Bot commented on FLINK-9303: --- GitHub user EAlexRojas opened a pull reques

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16471833#comment-16471833 ] Edward Rojas commented on FLINK-9303: - you are right, I'll update my code and create a

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466037#comment-16466037 ] Ted Yu commented on FLINK-9303: --- {code} + if (!removedPartitions.isEmp

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16465996#comment-16465996 ] Edward Rojas commented on FLINK-9303: - Hello,  I reported the issue on the mailing lis

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16465923#comment-16465923 ] Triones Deng commented on FLINK-9303: - [~tzulitai] i am interested in this issue. in y