@eliaslevy what do you mean by: > @pnowojski rather than releasing flink-connector-kafka-1.0, I would just > release flink-connector-kafka or flink-connector-kafka-new or some such, > without embedding the Kafka version into the connector artifact id, as it > will be updated with every new Kafka version.
If we release `flink-connector-kafka` without embedded Kafka version, we can not use reflections for transactional API. To make sure that our `exactly-once` kafka producer work, we must freeze kafka version. For example upgrading from `0.11.0` to `0.11.2` required some tiny change and so does the upgrade to `1.0` (as you can see in this PR). Another issue is what I have already said before: we can not provide one connector for kafka `0.10` and for `0.11+`, since `0.10` doesn't support transactions, so at the moment we can only provide one connector for versions from `0.11` to `2.0`. [ Full content available at: https://github.com/apache/flink/pull/6577 ] This message was relayed via gitbox.apache.org for [email protected]
