projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Added LICENSE file to root folder
[osm/MON.git]
/
osm_mon
/
test
/
core
/
kafka_test.py
diff --git
a/osm_mon/test/core/kafka_test.py
b/osm_mon/test/core/kafka_test.py
index
646e00b
..
7e4267c
100644
(file)
--- 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
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)
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',
group_id=None,
consumer_timeout_ms=10000,
auto_offset_reset='earliest',