Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Done
-
1.11.0
-
None
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