The reason is that Kafka 0.9+ provided a new consumer API which has more features and better performance.
Just like Flink's implementation : https://github.com/apache/flink/tree/master/flink-connectors. vinoyang Thanks.
The reason is that Kafka 0.9+ provided a new consumer API which has more features and better performance.
Just like Flink's implementation : https://github.com/apache/flink/tree/master/flink-connectors. vinoyang Thanks.