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?
- About Kafka08Fetcher and Kafka010Fetcher Jaxon Hu
- Re: About Kafka08Fetcher and Kafka010Fetcher Timo Walther
- Re: About Kafka08Fetcher and Kafka010Fetcher Tzu-Li (Gordon) Tai