You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/05/11 12:33:00 UTC
[jira] [Created] (FLINK-17619) Only set offset commit if group id
is configured for Kafka Table source
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)