[
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
[
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