[
https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460493#comment-17460493
]
Yuan Zhu commented on FLINK-25336:
----------------------------------
[~MartijnVisser] Thanks. Then what you provided is the Compatibility of
Confluent Platform and Apache Kafka.
Do we have the versions supported by Flink? I only find
[https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/kafka/#dependency]
.
According to the word here, clients are backwards compatible with broker
versions 0.10.0 or later. In fact, our compulsory config not support version
0.10.2. In that way, we just support higher version which I want to know.
> 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)
