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

option `properties.group.id` is not effective in kafka connector for finksql

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Not A Problem
    • 1.14.3
    • None
    • Table SQL / Client
    • None

    Description

      option `properties.group.id` is not effective in kafka connector for finksql.

      when I run this sql, I can read message from specific topic normaly. But I could not

      find the group named `test-group` in kafka server. 

      // ddl like this
      "CREATE TABLE ...
              "WITH ('connector' = 'kafka',
               'properties.bootstrap.servers' = '...'," +
              "'topic' = '...',"+
               "'scan.startup.mode'='latest-offset'," +
              "'properties.group.id' = 'test-group'," +
               "'format' = 'debezium-json')"; 

      Attachments

        Activity

          People

            Unassigned Unassigned
            SpongebobZ Spongebob
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: