[jira] [Created] (FLINK-25336) Kafka connector compatible problem in Flink sql

["Yuan Zhu (Jira)" <ji...@apache.org>]

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)