From 41d9f9cd568f17e72fbaa17429b7ac6dc8e8f90d Mon Sep 17 00:00:00 2001 From: "angre.garcia-gomez@ait.ac.at" Date: Wed, 7 Jan 2026 20:30:39 +0100 Subject: [PATCH] change name kafka method --- src/detectmatelibrary/readers/kafka_consumer.py | 2 +- tests/test_readers/test_reader_kafka.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/detectmatelibrary/readers/kafka_consumer.py b/src/detectmatelibrary/readers/kafka_consumer.py index 3c77eb7..7c5a264 100644 --- a/src/detectmatelibrary/readers/kafka_consumer.py +++ b/src/detectmatelibrary/readers/kafka_consumer.py @@ -9,7 +9,7 @@ class KafkaConfig(CoreReaderConfig): file: str = "" - method_type: str = "log_file_reader" + method_type: str = "kafka_reader" server: str = "" topic: str = "" diff --git a/tests/test_readers/test_reader_kafka.py b/tests/test_readers/test_reader_kafka.py index cbf31a3..1c1e4d6 100644 --- a/tests/test_readers/test_reader_kafka.py +++ b/tests/test_readers/test_reader_kafka.py @@ -8,7 +8,7 @@ class TestCaseKafka: @pytest.mark.skip(reason="Only run when the kafka server is running") def test_normal(self) -> None: config = KafkaConfig( - server="localhost:9092", topic="test_topic", group_id="b" + server="localhost:9092", topic="test_topic", group_id="bs" ) reader = KafkaReader(config=config)