@yanghua Sorry for commenting so late but I have a proposal. I would like to take this chance and fix a shortcoming in the dependency structure of our connectors. The connector dependencies form a chain, i.e. `0.11` depends on `0.10`, which depends on `0.9`, which depends on base. This itself makes the dependencies weird and can lead to problems when packaging a connector as a jar (as @twalthr found out, maybe you can comment about that here). Also, the base connector module has a dependency on `kafka_2.11`, which it shouldn't need, only `kafka-clients` should be required.
I think we can split it such that we have a base kafka connector module and the modules for the individual versions only depend on that, not on connectors for specific previous kafka versions. What do you think? [ Full content available at: https://github.com/apache/flink/pull/6577 ] This message was relayed via gitbox.apache.org for [email protected]
