Hi Eno, Yes, but the state() method only returns the global state of the KafkaStream application (ie: CREATED, RUNNING, REBALANCING, PENDING_SHUTDOWN, NOT_RUNNING).
An alternative to this KIP would be to change this method to return more information instead of adding a new method. 2017-03-01 13:46 GMT+01:00 Eno Thereska <eno.there...@gmail.com>: > 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 > > -- Florian HUSSONNOIS
