zentol opened a new pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762 This PR removes the Kafka 0.8/0.9 connectors. For 0.8 this is a fairly straight-forward removal, while for 0.9 several existing tests and classes have been merged into 0.10. I recommended reviewing commits individually. I first refactored the `KafkaConsumerThreadTest` to use an actual `Consumer` implementation instead of a mock, since the latter lead to the usual mocking issues when migrating the test to 0.10; namely API changes that went unnoticed by the mockito setup, causing test failures which took way too long to figure out. Next I removed the 0.8 connector, which was straight-forward since it is largely independent from other versions. The 0.9 removal is split into 2 commits: the first removes the 0.9 SQL jar, the second one the actual 0.9 connector. Since the 0.10 connector extended the 0.9 connected I had to merge the 0.9 connector into 0.10. This also presented some opportunities for simplifications (like the removal of call bridges).
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
