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?
