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)

Reply via email to