diff options
| author |   Bogumil Zebek <bogumil.zebek@nokia.com> | 2021-04-13 05:19:00 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2021-04-13 05:19:00 +0000 |
| commit | 5d0f3be91d693eaaba69fd778a09f015a51b4ca6 (patch) | |
| tree | 4d622e897e01950629331e7c0839e0d699cffbc4 /src/python/netconf_server | |
| parent | c9a9383bb208f8d846f2c83289635a1d4b95898c (diff) | |
| parent | 37bb5c99e085364cd71bbb44b225f0eb37a7aac7 (diff) | |
Merge "Fix Kafka consumer"
Diffstat (limited to 'src/python/netconf_server')
| -rw-r--r-- | src/python/netconf_server/kafka_consumer_factory.py | 2 | ||||
| -rw-r--r-- | src/python/netconf_server/netconf_kafka_client.py | 1 |
2 files changed, 2 insertions, 1 deletions
diff --git a/src/python/netconf_server/kafka_consumer_factory.py b/src/python/netconf_server/kafka_consumer_factory.py index 332cd21..43ef1cb 100644 --- a/src/python/netconf_server/kafka_consumer_factory.py +++ b/src/python/netconf_server/kafka_consumer_factory.py @@ -26,7 +26,7 @@ STANDARD_CHARSETS_UTF8 = 'utf-8' def provide_kafka_consumer(topic: str, server: str) -> KafkaConsumer: return KafkaConsumer(topic, - consumer_timeout_ms=1000, + consumer_timeout_ms=5000, group_id='netconf-group', auto_offset_reset='earliest', enable_auto_commit=False, diff --git a/src/python/netconf_server/netconf_kafka_client.py b/src/python/netconf_server/netconf_kafka_client.py index 53e7ecd..1f21604 100644 --- a/src/python/netconf_server/netconf_kafka_client.py +++ b/src/python/netconf_server/netconf_kafka_client.py @@ -79,5 +79,6 @@ class NetconfKafkaClient(object): message_value = message.value logger.info("Fetched config change %s" % message_value) messages.append(message_value) + consumer.close() return messages |