From 37bb5c99e085364cd71bbb44b225f0eb37a7aac7 Mon Sep 17 00:00:00 2001 From: Tomasz Pietruszkiewicz Date: Mon, 12 Apr 2021 14:33:41 +0200 Subject: Fix Kafka consumer Change-Id: I8b52e2d1859b964a582289e2f63d70272d60f39a Issue-ID: INT-1869 Signed-off-by: Tomasz Pietruszkiewicz --- src/python/netconf_server/kafka_consumer_factory.py | 2 +- src/python/netconf_server/netconf_kafka_client.py | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) (limited to 'src/python/netconf_server') 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 8687802..027bde1 100644 --- a/src/python/netconf_server/netconf_kafka_client.py +++ b/src/python/netconf_server/netconf_kafka_client.py @@ -75,5 +75,6 @@ class NetconfKafkaClient(object): message_value = message.value logger.info("Fetched config change %s" % message_value) messages.append(message_value) + consumer.close() return messages -- cgit 1.2.3-korg