diff options
| author |   Bartosz Gardziejewski <bartosz.gardziejewski@nokia.com> | 2021-04-12 14:21:34 +0200 |
|---|---|---|
| committer | Bartosz Gardziejewski <bartosz.gardziejewski@nokia.com> | 2021-04-12 14:23:27 +0200 |
| commit | c9a9383bb208f8d846f2c83289635a1d4b95898c (patch) | |
| tree | 6a179f362641e8bbb53ee230d764cdf6ccbfee97 /src/python/netconf_server/netconf_kafka_client.py | |
| parent | b7428c3c9dcbd6dfbff1b1c5eb5720d3b1098936 (diff) | |
change kafka send method to be async.
Issue-ID: INT-1869
Signed-off-by: Bartosz Gardziejewski <bartosz.gardziejewski@nokia.com>
Change-Id: I3301fd97f8f90443ebc4e3530b8c1fa10b5388c3
Diffstat (limited to 'src/python/netconf_server/netconf_kafka_client.py')
| -rw-r--r-- | src/python/netconf_server/netconf_kafka_client.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/python/netconf_server/netconf_kafka_client.py b/src/python/netconf_server/netconf_kafka_client.py index 8687802..53e7ecd 100644 --- a/src/python/netconf_server/netconf_kafka_client.py +++ b/src/python/netconf_server/netconf_kafka_client.py @@ -48,6 +48,10 @@ class NetconfKafkaClient(object): server = "{}:{}".format(host, port) producer = KafkaProducer( bootstrap_servers=server, + request_timeout_ms=15000, + retry_backoff_ms=1000, + max_in_flight_requests_per_connection=1, + retries=3, value_serializer=lambda x: dumps(x).encode(STANDARD_CHARSETS_UTF8) ) |