diff --git a/python/adapters/kafka/adapter_request_facade.py b/python/adapters/kafka/adapter_request_facade.py
index e1d65da..e104cbc 100644
--- a/python/adapters/kafka/adapter_request_facade.py
+++ b/python/adapters/kafka/adapter_request_facade.py
@@ -316,7 +316,7 @@
             return False, Error(code=ErrorCode.INVALID_PARAMETERS,
                                 reason="deviceid-invalid")
 
-        op = IntType
+        op = IntType()
         if outPort:
             outPort.Unpack(op)
         else: