[jira] [Commented] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553946#comment-17553946 ] Leonard Xu commented on FLINK-27041: Fixed in master(1.16):2b89dfe0d4c5c71a958fb1f07c5e6861e4bbe6a6

[jira] [Commented] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518720#comment-17518720 ] Martijn Visser commented on FLINK-27041: [~renqs] Done! > KafkaSource in batch mode failing on

[jira] [Commented] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518687#comment-17518687 ] Qingsheng Ren commented on FLINK-27041: --- Thanks for the ticket [~terxor] ! I checked the code and

[jira] [Commented] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516766#comment-17516766 ] Martijn Visser commented on FLINK-27041: [~renqs] Can you have a look? > KafkaSource in batch