diff --git a/extra/gagazmq/python/gagaworker.py b/extra/gagazmq/python/gagaworker.py
index 8d25c1f..efc6f95 100644
--- a/extra/gagazmq/python/gagaworker.py
+++ b/extra/gagazmq/python/gagaworker.py
@@ -26,7 +26,7 @@ def encodeMsg(self, msg):
         if self.compression:
             return msgpack.packb(msg)
         else:
-            return bytes(json.dumps(msg)).encode('utf-8')
+            return bytes(json.dumps(msg), encoding='utf-8')
 
     def decodeMsg(self, msg):
         if self.compression: