Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25336

Kafka connector compatible problem in Flink sql

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Minor
    • Resolution: Not A Bug
    • 1.14.0
    • None
    • Connectors / Kafka
    • Flink 1.14.0

      Kafka 0.10.2.1

    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

      Attachments

        1. log.jpg
          275 kB
          Yuan Zhu

        Activity

          People

            Unassigned Unassigned
            straw Yuan Zhu
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: