[KAFKA-10317] Global thread should honor shutdown signal during bootstrapping

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: streams
• Assignee: Matthias J. Sax
• Reporter: Matthias J. Sax
• Created: 28/Jul/20 03:52
• Updated: 28/Jul/20 03:57

Description

During startup, the global thread will bootstrap all global stores before it enters its main store-update-loop. The store-update-loop exits, when `KafkaStreams#close()` is called.

However, during the bootstrap phase there is no check if `KafkaStreams#close()` was called. And thus, KafkaStreams cannot be stopped during bootstrapping (ie, the bootstrapping cannot be interrupted).

To make Kafka Streams more responsive, we should check if `close()` was called during bootstrapping, too.

Note, that `KafkaStreams#start()` actually blocks during bootstrapping atm (cf KAFKA-7380) and thus we should fix both issue at once if possible.

Issue Links

• is related to: KAFKA-7380 Global thread restore blocks KafkaStreams#start()