Page History

...

In order to communicate the shutdown request from one client to the others we propose to update the SubcriptionInfoData to include a short field which will encode an error code. The error will be propagated through the metadata during a rejoin event via the assignor. The actual shutdown will be handled by the StreamsRebalnceListener, this is where the INCOMPLETE_SOURCE_TOPIC_METADATA error can also be handled.

We also propose adding an option to imitate the shutdown from `KafkaStreams.java`  which will search for an alive stream thread to start the shutdown. If there is not alive shutdown the method will return false indicating that the shutdown was not initiated.

Compatibility, Deprecation, and Migration Plan

...