Re: About Kafka08Fetcher and Kafka010Fetcher

Posted by Timo Walther on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/About-Kafka08Fetcher-and-Kafka010Fetcher-tp17499p17510.html

Maybe Gordon (in CC) can answer your question.


Am 1/1/18 um 3:36 PM schrieb Jaxon Hu:
> In Kafka08Fetcher, it use  Map<Node,SimpleConsumerThread> to manage
> multi-threads. But I notice in Kafka09Fetcher or Kafka010Fetcher, it's
> gone. So how Kafka09Fetcher implements multi-threads read partitions
> from kafka?