Description
Currently when streams are initialised and started with streams.start(), there is no way for the caller to know if the initialisation procedure (including starting tasks) is complete or not. Hence, the caller is forced to guess for how long to wait. It would be good to have a way to return the state of the streams to the caller.
One option would be to follow a similar approach in Kafka Server (BrokerStates.scala).
Would be good for example, to keep track of whether Kafka Streams is starting/running/rebalancing
Attachments
Issue Links
- relates to
-
KAFKA-3678 Fix stream integration test timeouts
- Resolved
- links to