Ok ... maybe I should add the Annotation prior to continuing my work on the AWS connector ...
Chris Am 04.03.18, 08:10 schrieb "vino yang" <yanghua1...@gmail.com>: 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.