diff --git a/confluent_server/confluent/core.py b/confluent_server/confluent/core.py
index 884ed809..a677309f 100644
--- a/confluent_server/confluent/core.py
+++ b/confluent_server/confluent/core.py
@@ -737,15 +737,15 @@ def _forward_rsp(connection, res):
        r = res.serialize()
     except AttributeError:
         if isinstance(res, Exception):
-            r = msgpack.packb(['Exception', str(res)], use_bin_type=True)
+            r = msgpack.packb(['Exception', str(res)], use_bin_type=False)
         else:
             r = msgpack.packb(
                 ['Exception', 'Unable to serialize response ' + repr(res)],
-                use_bin_type=True)
+                use_bin_type=False)
     except Exception:
         r = msgpack.packb(
                 ['Exception', 'Unable to serialize response ' + repr(res)],
-                use_bin_type=True)
+                use_bin_type=False)
     rlen = len(r)
     if not rlen:
         return
@@ -987,7 +987,7 @@ def dispatch_request(nodes, manager, element, configmanager, inputdata,
     dreq =  b'\x01\x03' + msgpack.packb(
         {'name': myname, 'nodes': list(nodes),
         'path': element,'tenant': configmanager.tenant,
-        'operation': operation, 'inputdata': inputdata}, use_bin_type=True)
+        'operation': operation, 'inputdata': inputdata}, use_bin_type=False)
     tlvdata.send(remote, {'dispatch': {'name': myname, 'length': len(dreq)}})
     remote.sendall(dreq)
     while True:
diff --git a/confluent_server/confluent/exceptions.py b/confluent_server/confluent/exceptions.py
index e184a02f..bce75763 100644
--- a/confluent_server/confluent/exceptions.py
+++ b/confluent_server/confluent/exceptions.py
@@ -37,7 +37,7 @@ class ConfluentException(Exception):
 
     def serialize(self):
         return msgpack.packb([self.__class__.__name__, [str(self)]],
-                             use_bin_type=True)
+                             use_bin_type=False)
 
     @property
     def apierrorstr(self):
@@ -132,7 +132,7 @@ class PubkeyInvalid(ConfluentException):
 
     def serialize(self):
         return msgpack.packb([self.__class__.__name__, self.myargs],
-                             use_bin_type=True)
+                             use_bin_type=False)
 
     def get_error_body(self):
         return self.errorbody
diff --git a/confluent_server/confluent/messages.py b/confluent_server/confluent/messages.py
index 07f84a14..9028725c 100644
--- a/confluent_server/confluent/messages.py
+++ b/confluent_server/confluent/messages.py
@@ -116,7 +116,7 @@ class ConfluentMessage(object):
     def serialize(self):
         msg = [self.__class__.__name__]
         msg.extend(self.myargs)
-        return msgpack.packb(msg, use_bin_type=True)
+        return msgpack.packb(msg, use_bin_type=False)
 
     @classmethod
     def deserialize(cls, data):
@@ -231,7 +231,7 @@ class ConfluentNodeError(object):
     def serialize(self):
         return msgpack.packb(
             [self.__class__.__name__, self.node, self.error],
-            use_bin_type=True)
+            use_bin_type=False)
 
     @classmethod
     def deserialize(cls, data):