[GitHub] eliaslevy commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1 connectors

[GitBox <gi...@apache.org>]

eliaslevy commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1 connectors
URL: https://github.com/apache/flink/pull/6577#issuecomment-418429475
 
 
   @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.
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services