X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=policy_module%2Fosm_policy_module%2Fcommon%2Fmon_client.py;fp=policy_module%2Fosm_policy_module%2Fcommon%2Fmon_client.py;h=3e8175775d8425f39de1d23fc9a28d196d76e2ca;hb=54634e6c12b80111e20a10c4f258dd0bfd4a944b;hp=0d86046c06fbf4ac8584b718d11438feff85b017;hpb=341c33b98b4951c5d617e040cf856d4011a09266;p=osm%2FMON.git

diff --git a/policy_module/osm_policy_module/common/mon_client.py b/policy_module/osm_policy_module/common/mon_client.py
index 0d86046..3e81757 100644
--- a/policy_module/osm_policy_module/common/mon_client.py
+++ b/policy_module/osm_policy_module/common/mon_client.py
@@ -50,7 +50,8 @@ class MonClient:
         future.get(timeout=60)
         consumer = KafkaConsumer(bootstrap_servers=self.kafka_server,
                                  key_deserializer=bytes.decode,
-                                 value_deserializer=bytes.decode)
+                                 value_deserializer=bytes.decode,
+                                 consumer_timeout_ms=10000)
         consumer.subscribe(['alarm_response'])
         for message in consumer:
             if message.key == 'create_alarm_response':