fix: correct isinstance check to include bytearray in kafka conversion

archy-rock3t-cloud · archy-rock3t-cloud · commit 89fabd9cbe47 · 2026-03-02T19:08:39.000+01:00
Signed-off-by: Artem Muterko &lt;artem@sopho.tech&gt;
diff --git a/cloudevents/kafka/conversion.py b/cloudevents/kafka/conversion.py
@@ -207,7 +207,7 @@ def to_structured(
         raise cloud_exceptions.DataMarshallerError(
             f"Failed to marshall data with error: {type(e).__name__}('{e}')"
         )
-    if isinstance(data, (bytes, bytes, memoryview)):
+    if isinstance(data, (bytes, bytearray, memoryview)):
         attrs["data_base64"] = base64.b64encode(data).decode("ascii")
     else:
         attrs["data"] = data

Original file line number	Diff line number	Diff line change
`@@ -207,7 +207,7 @@ def to_structured(`
`207`	`207`	`raise cloud_exceptions.DataMarshallerError(`
`208`	`208`	`f"Failed to marshall data with error: {type(e).__name__}('{e}')"`
`209`	`209`	`)`
`210`		`- if isinstance(data, (bytes, bytes, memoryview)):`
	`210`	`+ if isinstance(data, (bytes, bytearray, memoryview)):`
`211`	`211`	`attrs["data_base64"] = base64.b64encode(data).decode("ascii")`
`212`	`212`	`else:`
`213`	`213`	`attrs["data"] = data`