[jira] [Commented] (FLINK-34995) flink kafka connector source stuck when partition leader invalid

[ https://issues.apache.org/jira/browse/FLINK-34995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834629#comment-17834629 ] yansuopeng commented on FLINK-34995: https://github.com/apache/flink-connector-kafka

[jira] [Commented] (FLINK-34995) flink kafka connector source stuck when partition leader invalid

[ https://issues.apache.org/jira/browse/FLINK-34995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834581#comment-17834581 ] yansuopeng commented on FLINK-34995: [~martijnvisser]  Apologies for the confusion;

[jira] [Updated] (FLINK-34995) flink kafka connector source stuck when partition leader invalid

[ https://issues.apache.org/jira/browse/FLINK-34995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yansuopeng updated FLINK-34995: --- Issue Type: Improvement (was: Bug) > flink kafka connector source stuck when partition leader inval

[jira] [Updated] (FLINK-34995) flink kafka connector source stuck when partition leader invalid

[ https://issues.apache.org/jira/browse/FLINK-34995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yansuopeng updated FLINK-34995: --- Description: when partition leader invalid(leader=-1),  the flink streaming job using KafkaSource c

[jira] [Created] (FLINK-34995) flink kafka connector source stuck when partition leader invalid

yansuopeng created FLINK-34995: -- Summary: flink kafka connector source stuck when partition leader invalid Key: FLINK-34995 URL: https://issues.apache.org/jira/browse/FLINK-34995 Project: Flink