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?

Reply via email to