Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.10.0, 1.11.0
Description
Currently the KafkaTableSourceBase always creates the KafkaConsumer with the default offset commiting behavior that will try to commit on checkpoints.
However this will fail if group.id is not specified which is an optional parameter.
We should disable offset commiting if group.id wasnt specified.
Attachments
Issue Links
- relates to
-
FLINK-17802 Set offset commit only if group id is configured for new Kafka Table source
- Closed
- links to