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)