commit a38b7881e79edfbb1752233742d8dbbe9d7324ba
author Matteo Scandolo <matteo.scandolo@gmail.com> Mon Mar 23 15:40:34 2020 -0700
committer Matteo Scandolo <matteo.scandolo@gmail.com> Mon Mar 30 13:45:48 2020 -0700
tree 8227150a8888bc10db40298e2021fb66a7a50926
parent e6ff2bf0b2f7e291a0e9803c2fb5bbb7e625f641

When receiving a response from kafka, log the transaction Id

Change-Id: Ie49b0119c1c1425ec47fd50a93aa471f55a1941e

VERSION

diff --git a/VERSION b/VERSION
index eef2640..a724a9c 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-2.4.0-dev0
+2.4.0-dev

pyvoltha/adapters/kafka/kafka_inter_container_library.py

diff --git a/pyvoltha/adapters/kafka/kafka_inter_container_library.py b/pyvoltha/adapters/kafka/kafka_inter_container_library.py
index 2b32c24..b896aa4 100644
--- a/pyvoltha/adapters/kafka/kafka_inter_container_library.py
+++ b/pyvoltha/adapters/kafka/kafka_inter_container_library.py
@@ -398,7 +398,7 @@
                 log.debug("unsupported-msg", msg_type=type(message.body))
                 return None
             log.debug("parsed-response", type=message.header.type, from_topic=message.header.from_topic,
-                  to_topic=message.header.to_topic)
+                  to_topic=message.header.to_topic, transaction_id=message.header.id)
             return resp
         except Exception as e:
             log.exception("parsing-response-failed", msg=msg, e=e)
@@ -494,6 +494,7 @@
                                   to_topic=res_topic)
             elif message.header.type == MessageType.Value("RESPONSE"):
                 trns_id = self._to_string(message.header.id)
+                log.debug('received-response', transaction_id=trns_id)
                 if trns_id in self.transaction_id_deferred_map:
                     resp = self._parse_response(val)