You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2018/10/10 10:14:29 UTC

[GitHub] aljoscha edited a comment on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0

aljoscha edited a comment on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0
URL: https://github.com/apache/flink/pull/6703#issuecomment-428511766
 
 
   Yes, the reason (as I said) is that 1.0 still has the code in those `kafka.consumer...` packages while in 2.0 they are removed.
   
   Most of the Kafka classes used in `KafkaConsumerTestBase` are deprecated and have been removed in Kafka 2.0, that's the problem. Maybe it's enough to copy that to the Kafka 2.0 connector and make it work with Kafka 2.0

----------------------------------------------------------------
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