[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460512#comment-17460512 ]
Martijn Visser commented on FLINK-25336: ---------------------------------------- [~straw] Thanks for pointing that out, the documentation is not correct (anymore). Flink 1.14 ships with support for the Kafka Client 2.4.1, see https://github.com/apache/flink/blob/release-1.14/flink-connectors/flink-connector-kafka/pom.xml#L39 Flink 1.15 will ship with support for Kafka Client 2.8, see https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/pom.xml#L39 > 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 > Priority: Minor > Labels: Flink-sql, Kafka, flink > 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)