Details

      Description

      This new Kafka connector should use new interfaces proposed by FLIP-95, e.g. DynamicTableSource, DynamicTableSink, and Factory.

      The new proposed keys :

      Old key New key Note
      connector.type connector  
      connector.version N/A merged into 'connector' key
      connector.topic topic  
      connector.properties.zookeeper.connect properties.zookeeper.connect  
      connector.properties.bootstrap.servers properties.bootstrap.servers  
      connector.properties.group.id properties.group.id  
      connector.startup-mode scan.startup.mode  
      connector.specific-offsets scan.startup.specific-offsets  
      connector.startup-timestamp-millis scan.startup.timestamp-millis  
      connector.sink-partitioner sink.partitioner "fixed", or "round-robin", or a class name "org.mycompany.MyPartitioner"
      connector.sink-partitioner-class N/A merged into 'sink.partitioner', not needed anymore
      format.type format  

       

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                danny0405 Danny Chen
                Reporter:
                jark Jark Wu
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: