[
https://issues.apache.org/jira/browse/FLINK-27436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530329#comment-17530329
]
Spongebob commented on FLINK-27436:
-----------------------------------
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)
