diff --git a/VERSION b/VERSION
index 005119b..8e8299d 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-2.4.1
+2.4.2
diff --git a/pyvoltha/adapters/kafka/adapter_proxy.py b/pyvoltha/adapters/kafka/adapter_proxy.py
index 591c1c3..3e63433 100644
--- a/pyvoltha/adapters/kafka/adapter_proxy.py
+++ b/pyvoltha/adapters/kafka/adapter_proxy.py
@@ -97,7 +97,7 @@
             else:
                 h.id = uuid4().hex
 
-            h.timestamp = int(round(time.time() * 1000))
+            h.timestamp.GetCurrentTime()
             iaMsg = InterAdapterMessage()
             iaMsg.header.CopyFrom(h)
             iaMsg.body.Pack(msg)
diff --git a/pyvoltha/adapters/kafka/kafka_inter_container_library.py b/pyvoltha/adapters/kafka/kafka_inter_container_library.py
index 9e9a6be..1b005e7 100644
--- a/pyvoltha/adapters/kafka/kafka_inter_container_library.py
+++ b/pyvoltha/adapters/kafka/kafka_inter_container_library.py
@@ -339,7 +339,7 @@
                 request_body.response_required = True
                 response_required = True
 
-            request.header.timestamp = int(round(time.time() * 1000))
+            request.header.timestamp.GetCurrentTime()
             request_body.rpc = rpc
             for a, b in six.iteritems(kwargs):
                 arg = Argument()
@@ -372,8 +372,7 @@
             response = InterContainerMessage()
             response_body = InterContainerResponseBody()
             response.header.id = msg_header.id
-            response.header.timestamp = int(
-                round(time.time() * 1000))
+            response.header.timestamp.GetCurrentTime()
             response.header.type = MessageType.Value("RESPONSE")
             response.header.from_topic = msg_header.to_topic
             response.header.to_topic = msg_header.from_topic
diff --git a/requirements.txt b/requirements.txt
index b9243fb..8232468 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -18,4 +18,4 @@
 structlog==19.2.0
 transitions==0.6.4
 txaioetcd==0.3.0
-voltha-protos==3.3.0
+voltha-protos==3.3.2