[
https://issues.apache.org/jira/browse/FLINK-23146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369787#comment-17369787
]
JasonLee commented on FLINK-23146:
----------------------------------
Thank you for your reply, I will try to find the answer in ML
> Data cannot be consumed when upsert Kafka is used as the source
> ---------------------------------------------------------------
>
> Key: FLINK-23146
> URL: https://issues.apache.org/jira/browse/FLINK-23146
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.13.0
> Reporter: JasonLee
> Priority: Major
>
> The SQL is as follows
> {code:java}
> CREATE TABLE kafka_table (
> id string,
> mid string,
> JasonLee_name string,
> PRIMARY KEY (JasonLee_name) NOT ENFORCED
> )
> WITH (
> 'connector' = 'upsert-kafka',
> 'topic' = 'test',
> 'properties.bootstrap.servers' = 'master:9092,storm1:9092,storm2:9092',
> 'properties.group.id' = 'jason_flink_test',
> 'key.format' = 'json',
> 'key.json.ignore-parse-errors' = 'true',
> 'value.format' = 'json',
> 'value.json.fail-on-missing-field' = 'false',
> 'value.fields-include' = 'EXCEPT_KEY',
> 'key.fields-prefix' = 'JasonLee'
> );
> select * from kafka_table;
> {code}
> No data is consumed, either locally or in clusters
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
