Enable stats for system.kafka_consumers back by default

azat · azat · commit db7454994047 · 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
@@ -746,12 +746,10 @@ void StorageKafka::updateConfiguration(cppkafka::Configuration & kafka_config,
         /// materialized view attached.
         ///
         /// So for now it is disabled by default, until properly fixed.
-#if 0
         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.
         }
-#endif
 
         if (kafka_config.get("statistics.interval.ms") != "0")
         {

Original file line number	Diff line number	Diff line change
`@@ -746,12 +746,10 @@ void StorageKafka::updateConfiguration(cppkafka::Configuration & kafka_config,`
`746`	`746`	`/// materialized view attached.`
`747`	`747`	`///`
`748`	`748`	`/// So for now it is disabled by default, until properly fixed.`
`749`		`-#if 0`
`750`	`749`	`if (!config.has(config_prefix + "." + "statistics_interval_ms"))`
`751`	`750`	`{`
`752`	`751`	`kafka_config.set("statistics.interval.ms", "3000"); // every 3 seconds by default. set to 0 to disable.`
`753`	`752`	`}`
`754`		`-#endif`
`755`	`753`
`756`	`754`	`if (kafka_config.get("statistics.interval.ms") != "0")`
`757`	`755`	`{`