@pnowojski I mean that the Flink Kafka connector need not embedded the Kafka version into the connector artifact name. Obviously, the connector would depend on a specific Kafka client version artifact that would be targeted by the reflection code.
Re: 0.10. As I mentioned above, you can use a newer client against a 0.10 broker. If you try to use transactions against the 0.10 broker, the client will raise `UnsupportedVersionException`. That will let the connector know that the broker does not support transactions. >From the `KafkaProducer` documentation: > This client can communicate with brokers that are version 0.10.0 or newer. > Older or newer brokers > may not support certain client features. For instance, the transactional APIs > need broker versions > 0.11.0 or later. You will receive an UnsupportedVersionException when > invoking an API that is not > available in the running broker version. [ Full content available at: https://github.com/apache/flink/pull/6577 ] This message was relayed via gitbox.apache.org for [email protected]
