[jira] (FLINK-27436) option `properties.group.id` is not effective in kafka connector for finksql

["Spongebob (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-27436 ]


    Spongebob deleted comment on FLINK-27436:
    -----------------------------------

was (Author: spongebobz):
Hi [~martijnvisser] , When I deploy my flinksql application that contains multiple insertion sql that are both executed by one statementSet to standalone cluster,

It did not tigger checkpoints despite some source table already got data input.

> option `properties.group.id` is not effective in kafka connector for finksql
> ----------------------------------------------------------------------------
>
>                 Key: FLINK-27436
>                 URL: https://issues.apache.org/jira/browse/FLINK-27436
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Client
>    Affects Versions: 1.14.3
>            Reporter: Spongebob
>            Priority: Major
>
> option `properties.group.id` is not effective in kafka connector for finksql.
> when I run this sql, I can read message from specific topic normaly. But I could not
> find the group named `test-group` in kafka server. 
> {code:java}
> // ddl like this
> "CREATE TABLE ...
>         "WITH ('connector' = 'kafka',
>          'properties.bootstrap.servers' = '...'," +
>         "'topic' = '...',"+
>          "'scan.startup.mode'='latest-offset'," +
>         "'properties.group.id' = 'test-group'," +
>          "'format' = 'debezium-json')"; {code}



--
This message was sent by Atlassian Jira
(v8.20.7#820007)