From d664c1ad10de8e76e47704964ad8e47b33cf24da Mon Sep 17 00:00:00 2001 From: Benjamin Diaz Date: Tue, 9 Oct 2018 20:07:43 -0300 Subject: [PATCH] Adds unique group_id to KafkaConsumer used in MonClient Signed-off-by: Benjamin Diaz --- osm_policy_module/common/mon_client.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/osm_policy_module/common/mon_client.py b/osm_policy_module/common/mon_client.py index 724fe83..5d2416e 100644 --- a/osm_policy_module/common/mon_client.py +++ b/osm_policy_module/common/mon_client.py @@ -53,7 +53,8 @@ class MonClient: consumer = KafkaConsumer(bootstrap_servers=self.kafka_server, key_deserializer=bytes.decode, value_deserializer=bytes.decode, - consumer_timeout_ms=10000) + consumer_timeout_ms=10000, + group_id='mon-client-' + str(uuid.uuid4())) consumer.subscribe(['alarm_response']) for message in consumer: if message.key == 'create_alarm_response': -- 2.25.1