[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460562#comment-17460562 ]
Yuan Zhu commented on FLINK-25336: ---------------------------------- [~MartijnVisser] [~JasonLee] Thanks for your help. I get it. > 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)