diff options
Diffstat (limited to 'src/python/netconf_server/kafka_consumer_factory.py')
| -rw-r--r-- | src/python/netconf_server/kafka_consumer_factory.py | 2 |
1 files changed, 1 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, |