X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Ftest%2Fcore%2Fkafka_test.py;h=7e4267c3bc12c34304d5da35bf47c084573900f3;hb=bbbc9f6af36cea7a55d478020b7f385f792fb91d;hp=646e00bb04133ded90c638fabff3b137dee7e46e;hpb=c7397b95dbaeebd7d872779eec809daed9e487cc;p=osm%2FMON.git

diff --git a/osm_mon/test/core/kafka_test.py b/osm_mon/test/core/kafka_test.py
index 646e00b..7e4267c 100644
--- a/osm_mon/test/core/kafka_test.py
+++ b/osm_mon/test/core/kafka_test.py
@@ -30,13 +30,12 @@ import threading
 import pytest
 from kafka import KafkaConsumer, KafkaProducer
 
-def test_end_to_end(kafka_broker):
-    connect_str = ':'.join([kafka_broker.host, str(kafka_broker.port)])
-    producer = KafkaProducer(bootstrap_servers=connect_str,
+def test_end_to_end():
+    producer = KafkaProducer(bootstrap_servers='localhost:9092',
                              retries=5,
                              max_block_ms=10000,
                              value_serializer=str.encode)
-    consumer = KafkaConsumer(bootstrap_servers=connect_str,
+    consumer = KafkaConsumer(bootstrap_servers='localhost:9092',
                              group_id=None,
                              consumer_timeout_ms=10000,
                              auto_offset_reset='earliest',