Update comment for statistics.interval.ms librdkafka option

azat · azat · commit 1f03a210335b · 2023-12-27T09:49:07.000+01:00
Signed-off-by: Azat Khuzhin &lt;a.khuzhin@semrush.com&gt;
diff --git a/src/Storages/Kafka/StorageKafka.cpp b/src/Storages/Kafka/StorageKafka.cpp
@@ -798,14 +798,10 @@ void StorageKafka::updateConfiguration(cppkafka::Configuration & kafka_config)
 
     /// NOTE: statistics should be consumed, otherwise it creates too much
     /// entries in the queue, that leads to memory leak and slow shutdown.
-    ///
-    /// This is the case when you have kafka table but no SELECT from it or
-    /// materialized view attached.
-    ///
-    /// So for now it is disabled by default, until properly fixed.
     if (!config.has(config_prefix + "." + "statistics_interval_ms"))
     {
-        kafka_config.set("statistics.interval.ms", "3000"); // every 3 seconds by default. set to 0 to disable.
+        // every 3 seconds by default. set to 0 to disable.
+        kafka_config.set("statistics.interval.ms", "3000");
     }
 
     // Configure interceptor to change thread name
