[FLINK-25336] Kafka connector compatible problem in Flink sql

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Not A Bug
• Affects Version/s: 1.14.0
• Component/s: Connectors / Kafka
• Labels: Flink-sql Kafka flink

Environment

Flink 1.14.0

Kafka 0.10.2.1

Language

Java

• Assignee: Unassigned
• Reporter: Yuan Zhu
• Created: 16/Dec/21 03:16
• Updated: 29/Aug/22 12:49
• Resolved: 16/Dec/21 10:34

Description

When I use sql to query kafka table, like

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;

It will encounter an exception:

org.apache.kafka.common.errors.UnsupportedVersionException: MetadataRequest versions older than 4 don't support the allowAutoTopicCreation field