Properly set shutdown_called in StorageKafka::shutdown()

Fixes: ClickHouse#42777 Signed-off-by: Azat Khuzhin <a.khuzhin@semrush.com>
azat · Dec 27, 2023 · 51d4f58 · 51d4f58
1 parent 123d63e
commit 51d4f58
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/Storages/Kafka/StorageKafka.cpp b/src/Storages/Kafka/StorageKafka.cpp
@@ -436,6 +436,8 @@ void StorageKafka::startup()
 
 void StorageKafka::shutdown(bool)
 {
+    shutdown_called = true;
+
     for (auto & task : tasks)
     {
         // Interrupt streaming thread