About Kafka08Fetcher and Kafka010Fetcher

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

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?