...
In Kafka Streams, a method KafkaStreams#isConnected() will be added. When something happens unexpectedly which causes the connection to vanish, KafkaStreams#isConnected()
will return false. 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. KafkaStreams#isConnected
will look like this:
...
language | java |
---|---|
theme | Eclipse |
title | KafkaStreams#isConnected() |
...
We would add a new state to getState()
so that it will return State.DISCONNECTED
should the consumer be disconnected to the broker.
This would also mean that a new method would be added to KafkaConsumer to allow the StreamThread to query the health of the connection.
...