[FLINK-17619] Only set offset commit if group id is configured for Kafka Table source

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0, 1.11.0
• Fix Version/s: 1.11.0
• Component/s: Connectors / Kafka, Table SQL / API
• Labels: pull-request-available
• Assignee: Gyula Fora
• Reporter: Gyula Fora
• Created: 11/May/20 12:32
• Updated: 08/Nov/24 05:20
• Resolved: 19/May/20 14:36

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.

Issue Links

• causes: FLINK-36674 Flink will not commit to kafka if checkpointing is not enabled
• relates to: FLINK-17802 Set offset commit only if group id is configured for new Kafka Table source
• links to: GitHub Pull Request #12117
• links to: GitHub Pull Request #12250