Enable stats for system.kafka_consumers back by default

Signed-off-by: Azat Khuzhin <a.khuzhin@semrush.com>
This commit is contained in:
Azat Khuzhin 2023-12-14 12:15:24 +01:00
parent e7592c140e
commit db74549940

View File

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