pnowojski edited a comment on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1 connectors URL: https://github.com/apache/flink/pull/6577#issuecomment-417598718 @eliaslevy ok now I get your point, sorry for confusion. In that case my objection is mostly invalid, since we should be able to use the latest kafka client (for example 2.0) to talk with all the previous versions. I expect that the latest version should be also the most stable one. @yanghua in the option proposed by @eliaslevy we would only be using one version (the latest) of the kafka client, thus there would be no special cases. In this scenario, when we are upgrading from `0.11` to `1.0`, effectively we would drop `0.11` connector code, replacing it with `1.0` code. Generally speaking I would be in favour of such option. However there would be two questions needing an answer: 1. after upgrading our connector from `0.11` to `1.0`, do we keep old `flink-connector-kafka-0.11` module with small tiny proxy classes redirecting to `flink-connector-kafka-1.0` to provide painless migration? 2. what about testing? Should we still test `flink-connector-kafka-1.0` against `0.11` brokers?
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
