...

In Kafka Streams, State.DISCONNECTED  will be added. When something happens in Kafka Streams, such as an unexpected crash or error, KafkaStreams#state()  unexpectedly which causes the connection to vanish, the Kafka Streams application will return State.DISCONNECTED. Please note that the difference between DISCONNECTED  and DEAD  is that KafkaStreams, when it is in its dead state, is no longer running. While in the DISCONNECTED  case, it would still be alive, but could not connect to broker.

Proposed Changes

We would query individual StreamThreads for their individual status and update the state accordingly. 

...