Thanks Florian, Have you had a chance to look at the new state methods in 0.10.2, e.g., KafkaStreams.state()?
Thanks Eno > On 1 Mar 2017, at 11:54, Florian Hussonnois <fhussonn...@gmail.com> wrote: > > 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
