From: Benjamin Diaz Date: Tue, 9 Oct 2018 23:07:43 +0000 (-0300) Subject: Adds unique group_id to KafkaConsumer used in MonClient X-Git-Tag: v5.0.0~13 X-Git-Url: https://osm.etsi.org/gitweb/?a=commitdiff_plain;ds=sidebyside;h=d664c1ad10de8e76e47704964ad8e47b33cf24da;p=osm%2FPOL.git Adds unique group_id to KafkaConsumer used in MonClient Signed-off-by: Benjamin Diaz --- 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':