Hi all, As one partition only allows one consumer thread to claim, there would be a case that some consumer threads are idle when we over assign consumer threads. Is there anyway I can monitor the number of active threads(not active threads in ExecutorService, but threads are actually consuming messages.) in the Kafka consumers? I am using 0.8.2.1 client, looks like the KafkaStream class doesn't have any partition assignment info.
Thanks. -- Yifan
