Hi Andreas,
This is not an intended behavior. Could you file a JIRA and describe your
Kafka broker version / Streams API version, the logs / stack traces you saw
in that ticket? I'd like to help investigate and walk you through the
process to contribute a fix if you are interested and have time.
Hi All,
We recently implemented a health check for a Kafka Streams based application.
The health check is simply checking the state of Kafka Streams by calling
KafkaStreams.state(). It reports healthy if it’s not in PENDING_SHUTDOWN or
NOT_RUNNING states.
We truly appreciate having the
