[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16644778#comment-16644778
]
ASF GitHub Bot commented on FLINK-9697:
---------------------------------------
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:
[email protected]
> Provide connector for Kafka 2.0.0
> ---------------------------------
>
> Key: FLINK-9697
> URL: https://issues.apache.org/jira/browse/FLINK-9697
> Project: Flink
> Issue Type: Improvement
> Reporter: Ted Yu
> Assignee: vinoyang
> Priority: Major
> Labels: pull-request-available
>
> Kafka 2.0.0 would be released soon.
> Here is vote thread:
> [http://search-hadoop.com/m/Kafka/uyzND1vxnEd23QLxb?subj=+VOTE+2+0+0+RC1]
> We should provide connector for Kafka 2.0.0 once it is released.
> Upgrade to 2.0 documentation :
> http://kafka.apache.org/20/documentation.html#upgrade_2_0_0
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
