@pnowojski If we don't consider the failed test case, then this PR applies to both Kafka client 1.0 and kafka client 2.0. Basically it also applies to kafka 0.11 (except for a reflection field of the producer transaction and the associated test code). So, I want to hear your opinion. Should we build a connector that fits the three versions of kafka client next?
[ Full content available at: https://github.com/apache/flink/pull/6703 ] This message was relayed via gitbox.apache.org for [email protected]
