unicode

Author: fangnx

src/confluent_kafka/kafkatest/verifiable_client.py

@@ -61,8 +61,8 @@ def err(self, s, term=False):
     def send(self, d):
         """ Send dict as JSON to stdout for consumtion by kafkatest handler """
         d['_time'] = str(datetime.datetime.now())
-        self.dbg('SEND: %s' % orjson.dumps(d))
-        sys.stdout.write('%s\n' % orjson.dumps(d))
+        self.dbg('SEND: %s' % orjson.dumps(d).decode("utf-8"))
+        sys.stdout.write('%s\n' % orjson.dumps(d).decode("utf-8"))
         sys.stdout.flush()
 
     @staticmethod

src/confluent_kafka/schema_registry/_async/json_schema.py

@@ -221,7 +221,7 @@ async def __init_impl(
         else:
             self._schema = None
 
-        self._json_encode = json_encode or orjson.dumps
+        self._json_encode = json_encode or (lambda x: orjson.dumps(x).decode("utf-8"))
         self._registry = schema_registry_client
         self._rule_registry = (
             rule_registry if rule_registry else RuleRegistry.get_global_instance()

src/confluent_kafka/schema_registry/_async/schema_registry_client.py

@@ -416,7 +416,7 @@ async def send_request(
                              " application/json"}
 
         if body is not None:
-            body = orjson.dumps(body)
+            body = orjson.dumps(x).decode('utf-8')
             headers = {'Content-Length': str(len(body)),
                        'Content-Type': "application/vnd.schemaregistry.v1+json"}
 

src/confluent_kafka/schema_registry/_sync/json_schema.py

@@ -221,7 +221,7 @@ def __init_impl(
         else:
             self._schema = None
 
-        self._json_encode = json_encode or orjson.dumps
+        self._json_encode = json_encode or (lambda x: orjson.dumps(x).decode("utf-8"))
         self._registry = schema_registry_client
         self._rule_registry = (
             rule_registry if rule_registry else RuleRegistry.get_global_instance()

src/confluent_kafka/schema_registry/_sync/schema_registry_client.py

@@ -416,7 +416,7 @@ def send_request(
                              " application/json"}
 
         if body is not None:
-            body = orjson.dumps(body)
+            body = orjson.dumps(x).decode('utf-8')
             headers = {'Content-Length': str(len(body)),
                        'Content-Type': "application/vnd.schemaregistry.v1+json"}