I think that's a good plan. Before doing anything fancy, it would be nice to really do a PoC and test the compatibility (upgrade connector to Kafka 2.0 and test it using our tests against Kafka 0.11, 1.0, 1.1, ..., 2.0)
[ Full content available at: https://github.com/apache/flink/pull/6577 ] This message was relayed via gitbox.apache.org for [email protected]
