JasonLee created FLINK-23146:
--------------------------------
Summary: 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
Fix For: 1.14.0
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)
