THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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.
...