Code Review
/
sim
/
a1-interface.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
NONRTRIC-955: Fix unit test 404 issue
[sim/a1-interface.git]
/
near-rt-ric-simulator
/
test
/
KAFKA_DISPATCHER
/
src
/
maincommon.py
diff --git
a/near-rt-ric-simulator/test/KAFKA_DISPATCHER/src/maincommon.py
b/near-rt-ric-simulator/test/KAFKA_DISPATCHER/src/maincommon.py
index
c534acb
..
d5b65ae
100644
(file)
--- a/
near-rt-ric-simulator/test/KAFKA_DISPATCHER/src/maincommon.py
+++ b/
near-rt-ric-simulator/test/KAFKA_DISPATCHER/src/maincommon.py
@@
-65,9
+65,13
@@
def create_kafka_producer():
# https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html
def create_kafka_consumer():
consumer = KafkaConsumer(
# https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html
def create_kafka_consumer():
consumer = KafkaConsumer(
- #
KAFKA_TOPIC_RES,
+ #
kafka cluster endpoint
bootstrap_servers = MSG_BROKER_URL,
bootstrap_servers = MSG_BROKER_URL,
+ # move to the earliest or latest available message
auto_offset_reset = 'earliest',
auto_offset_reset = 'earliest',
+ # number of milliseconds to block during message iteration
+ # if no new message available during this period of time, iteration through a for-loop will stop automatically
+ consumer_timeout_ms = 100,
value_deserializer = lambda m: json.loads(m.decode('ascii')),
#enable_auto_commit=False
)
value_deserializer = lambda m: json.loads(m.decode('ascii')),
#enable_auto_commit=False
)