[jira] [Commented] (FLINK-27348) Flink KafkaSource doesn't set groupId

2022-04-22 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526291#comment-17526291 ] Ahmet Gürbüz commented on FLINK-27348: -- How will i do that with KafkaSource? [~Jiangang]  > Flink

[jira] [Commented] (FLINK-27348) Flink KafkaSource doesn't set groupId

2022-04-21 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526185#comment-17526185 ] Liu commented on FLINK-27348: - Have you committed the kafka offset? > Flink KafkaSource doesn't set groupId