diff --git a/VERSION b/VERSION
index 73462a5..f225a78 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-2.5.1
+2.5.2
diff --git a/pyvoltha/adapters/kafka/core_proxy.py b/pyvoltha/adapters/kafka/core_proxy.py
index 5c6ab33..a756855 100644
--- a/pyvoltha/adapters/kafka/core_proxy.py
+++ b/pyvoltha/adapters/kafka/core_proxy.py
@@ -415,10 +415,13 @@
     @inlineCallbacks
     def ports_state_update(self,
                           device_id,
+                          port_type_filter,
                           oper_status):
         log.debug("ports_state_update", device_id=device_id, oper_status=oper_status)
         id = ID()
         id.id = device_id
+        t_filter = IntType()
+        t_filter.val = port_type_filter
         o_status = IntType()
         o_status.val = oper_status
 
@@ -431,8 +434,9 @@
                                 to_topic=to_topic,
                                 reply_topic=reply_topic,
                                 device_id=id,
+                                port_type_filter=t_filter,
                                 oper_status=o_status)
-        log.debug("ports_state_update_response", device_id=device_id, oper_status=oper_status, response=res)
+        log.debug("ports_state_update_response", device_id=device_id, port_type_filter=port_type_filter, oper_status=oper_status, response=res)
         returnValue(res)
 
     def port_removed(device_id, port):
diff --git a/requirements.txt b/requirements.txt
index e293cea..9b2d2cb 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.4.0
+voltha-protos==3.4.1