diff --git a/src/sentry/profiles/consumers/process/factory.py b/src/sentry/profiles/consumers/process/factory.py index 2b21cdc2da4b61..c3205289d93a4a 100644 --- a/src/sentry/profiles/consumers/process/factory.py +++ b/src/sentry/profiles/consumers/process/factory.py @@ -34,7 +34,7 @@ def process_message(message: Message[KafkaPayload]) -> None: message.payload.value, level=options.get("taskworker.try_compress.profile_metrics.level"), ) - ) + ).decode("utf-8") metrics.distribution( "profiling.profile_metrics.compressed_bytes", len(b64encoded_compressed),