Hi all, I have just created KIP-130 to add a new method to the KafkaStreams API in order to expose the states of threads and active tasks.
https://cwiki.apache.org/confluence/display/KAFKA/KIP+130%3A+Expose+states+of+active+tasks+to+KafkaStreams+public+API Thanks, -- Florian HUSSONNOIS
