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 = "<PLACEHOLDER>"
-    method_type: str = "log_file_reader"
+    method_type: str = "kafka_reader"
 
     server: str = "<PLACEHOLDER>"
     topic: str = "<PLACEHOLDER>"
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)