Yuan Zhu created FLINK-25336:
--------------------------------
Summary: Kafka connector compatible problem in Flink sql
Key: FLINK-25336
URL: https://issues.apache.org/jira/browse/FLINK-25336
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.14.0
Environment: Flink 1.14.0
Kafka 0.10.2.1
Reporter: Yuan Zhu
Attachments: log.jpg
When I use sql to query kafka table, like
{code:java}
create table `kfk`
(
user_id VARCHAR
) with (
'connector' = 'kafka',
'topic' = 'test',
'properties.bootstrap.servers' = 'localhost:9092',
'format' = 'json',
'scan.startup.mode' = 'timestamp',
'scan.startup.timestamp-millis' = '1639411200000',
'properties.group.id' = 'test'
);
CREATE TABLE print_table (user_id varchar) WITH ('connector' = 'print');
insert into print_table select user_id from kfk;{code}
It will encounter an exception:
org.apache.kafka.common.errors.UnsupportedVersionException: MetadataRequest
versions older than 4 don't support the allowAutoTopicCreation field !log.jpg!
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
