Hi guys, How about this idea, I think we should support kafka's new client API.
2018-03-04 15:10 GMT+08:00 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. > >
