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

refactor kafka sql connector to use just one shade to compatible 0.10.0.2 +

    XMLWordPrintableJSON

Details

    Description

      Flink master supports 0.10/0.11/2.x, with three flink-sql-connector shade jar currently (1.12-snapshot).

      As we all know ,kafka client is compatible after 0.10.2.x, so we can use kafka client 2.x to access to brocker server are  0.10/0.11/2.x. 

      So we can just use one kafka sql shade jar. 

      for this , we should do 2 things

      1) refactor to 1 shade jar

      2) rename flink-kafka-connector mudules with same qualified name in case of conflicts such as NoSuchMethod or ClassNotFound error

      Attachments

        Activity

          People

            Unassigned Unassigned
            jackylau Jacky Lau
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: