| commit | 6dff9c9257d636a5b7939223642434d2b803d4e8 | [log] [tgz] |
|---|---|---|
| author | Shad Ansari <shad@opennetworking.org> | Tue Apr 23 15:00:06 2019 -0700 |
| committer | Shad Ansari <shad@opennetworking.org> | Fri May 17 06:08:47 2019 +0000 |
| tree | 5454d1347c6aad449e498a4b768d8da8f5642681 | |
| parent | 4c19b85dee31e3ceadbc120827f10edacf6aa709 [diff] |
Exception handling around kafka produce() Change-Id: I8d87b4b5363442477238484b58783f4c452c4bbd
diff --git a/voltha/adapters/openolt/openolt_kafka_proxy.py b/voltha/adapters/openolt/openolt_kafka_proxy.py index 1541bd9..0d3a79a 100644 --- a/voltha/adapters/openolt/openolt_kafka_proxy.py +++ b/voltha/adapters/openolt/openolt_kafka_proxy.py
@@ -64,7 +64,10 @@ self.kproducer = Producer(**conf) def send_message(self, topic, msg, key=None): - self.kproducer.produce(topic, msg) + try: + self.kproducer.produce(topic, msg) + except BufferError: + log.error('Local producer queue is full') def is_faulty(self): return self.faulty