diff --git a/src/Storages/Kafka/StorageKafka.cpp b/src/Storages/Kafka/StorageKafka.cpp index 4496d4a4450..402e5d2fab2 100644 --- 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") {