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

[Shang Yuanchun (Jira)]

Gyula Fora created FLINK-17619:
----------------------------------

             Summary: Only set offset commit if group id is configured for Kafka Table source
                 Key: FLINK-17619
                 URL: https://issues.apache.org/jira/browse/FLINK-17619
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka, Table SQL / API
    Affects Versions: 1.10.0, 1.11.0
            Reporter: Gyula Fora
            Assignee: Gyula Fora


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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)