From ccdcc2b97d3437c02f5a5711972296cde42450d9 Mon Sep 17 00:00:00 2001 From: Martin Zink Date: Thu, 27 Feb 2025 15:27:27 +0100 Subject: [PATCH] fix --- extensions/kafka/ConsumeKafka.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/extensions/kafka/ConsumeKafka.cpp b/extensions/kafka/ConsumeKafka.cpp index 12c3374f6c..8b82ca5acf 100644 --- a/extensions/kafka/ConsumeKafka.cpp +++ b/extensions/kafka/ConsumeKafka.cpp @@ -102,7 +102,7 @@ void ConsumeKafka::createTopicPartitionList() { kf_topic_partition_list_ = utils::rd_kafka_topic_partition_list_unique_ptr{ rd_kafka_topic_partition_list_new(gsl::narrow(topic_names_.size()))}; - if (topic_name_format_ == consume_kafka::TopicNameFormatEnum::Names) { + if (topic_name_format_ == consume_kafka::TopicNameFormatEnum::Patterns) { for (const std::string &topic: topic_names_) { const std::string regex_format = "^" + topic; rd_kafka_topic_partition_list_add(kf_topic_partition_list_.get(), regex_format.c_str(), RD_KAFKA_PARTITION_UA);