I’m not sure if auto detecting support for transactions is worth the trouble. It might be as easy as switching to at least once mode, but it might be just easier to support only Kafka 0.11+ with this unified connector.
[ Full content available at: https://github.com/apache/flink/pull/6577 ] This message was relayed via gitbox.apache.org for [email protected]
