fix: use Encoding.UTF8.GetBytes instead of JsonSerializer for CloudEvent parsing

JsonSerializer.SerializeToUtf8Bytes on an already-JSON string wraps it in
quotes, breaking DecodeStructuredModeMessageAsync. Switch to
Encoding.UTF8.GetBytes to pass the raw JSON bytes unchanged across Kafka,
Service Bus, and Google Pub/Sub workers.

Co-Authored-By: Claude Sonnet 4.6 (1M context) <noreply@anthropic.com>

Author: jeastham1993

user-management/src/Stickerlandia.UserManagement.Agnostic/KafkaStickerPrintedWorker.cs

@@ -11,7 +11,6 @@
 // Catching generic exceptions is not recommended, but in this case we want to catch all exceptions so that a failure in outbox processing does not crash the application.
 #pragma warning disable CA1031
 
-using System.Text.Json;
 using CloudNative.CloudEvents;
 using CloudNative.CloudEvents.SystemTextJson;
 using Confluent.Kafka;
@@ -33,7 +32,6 @@ public class KafkaStickerPrintedWorker(
     ProducerConfig producerConfig)
     : IMessagingWorker
 {
-    private readonly JsonSerializerOptions _jsonSerializerOptions = new() { PropertyNameCaseInsensitive = true };
     private const string topic = "printJobs.completed.v1";
     private const string dlqTopic = "printJobs.completed.v1.dlq";
 
@@ -46,7 +44,7 @@ private async Task<bool> ProcessMessageAsync(StickerPrintedHandler handler,
 
         Log.ReceivedMessage(logger, "kafka");
 
-        var detailBytes = JsonSerializer.SerializeToUtf8Bytes(consumeResult.Message.Value, _jsonSerializerOptions);
+        var detailBytes = System.Text.Encoding.UTF8.GetBytes(consumeResult.Message.Value);
         var formatter = new JsonEventFormatter<StickerPrintedEventV1>();
         var cloudEvent = await formatter.DecodeStructuredModeMessageAsync(
             new MemoryStream(detailBytes), null, new List<CloudEventAttribute>());

user-management/src/Stickerlandia.UserManagement.Azure/ServiceBusStickerPrintedWorker.cs

@@ -8,7 +8,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2025 Datadog, Inc.
 
-using System.Text.Json;
 using Azure.Messaging.ServiceBus;
 using CloudNative.CloudEvents;
 using CloudNative.CloudEvents.SystemTextJson;
@@ -26,7 +25,6 @@ namespace Stickerlandia.UserManagement.Azure;
 [AsyncApi]
 public class ServiceBusStickerPrintedWorker : IMessagingWorker
 {
-    private readonly JsonSerializerOptions _jsonSerializerOptions = new() { PropertyNameCaseInsensitive = true };
     private readonly IServiceScopeFactory _serviceScopeFactory;
     private readonly ILogger<ServiceBusStickerPrintedWorker> _logger;
     private readonly ServiceBusProcessor _processor;
@@ -59,7 +57,7 @@ private async Task ProcessMessageAsync(ProcessMessageEventArgs args)
         var messageBody = args.Message.Body.ToString();
         Log.ReceivedMessage(_logger, "ServiceBus");
 
-        var detailBytes = JsonSerializer.SerializeToUtf8Bytes(messageBody, _jsonSerializerOptions);
+        var detailBytes = System.Text.Encoding.UTF8.GetBytes(messageBody);
         var formatter = new JsonEventFormatter<StickerPrintedEventV1>();
         var cloudEvent = await formatter.DecodeStructuredModeMessageAsync(
             new MemoryStream(detailBytes), null, new List<CloudEventAttribute>());

user-management/src/Stickerlandia.UserManagement.GCP/GooglePubSubStickerPrintedWorker.cs

@@ -8,7 +8,6 @@
 // This product includes software developed at Datadog (https://www.datadoghq.com/).
 // Copyright 2025 Datadog, Inc.
 
-using System.Text.Json;
 using CloudNative.CloudEvents;
 using CloudNative.CloudEvents.SystemTextJson;
 using Datadog.Trace;
@@ -31,8 +30,6 @@ public class GooglePubSubStickerPrintedWorker(
     [FromKeyedServices("printJobs.completed.v1")]
     SubscriberClient subscriber) : IMessagingWorker
 {
-    private readonly JsonSerializerOptions _jsonSerializerOptions = new() { PropertyNameCaseInsensitive = true };
-    
     private Task? _task;
 
     public Task StartAsync()
@@ -84,7 +81,7 @@ public async Task StopAsync(CancellationToken cancellationToken)
         using var scope = serviceScopeFactory.CreateScope();
         var handler = scope.ServiceProvider.GetRequiredService<StickerPrintedHandler>();
 
-        var detailBytes = JsonSerializer.SerializeToUtf8Bytes(messageText, _jsonSerializerOptions);
+        var detailBytes = System.Text.Encoding.UTF8.GetBytes(messageText);
         var formatter = new JsonEventFormatter<StickerPrintedEventV1>();
         var cloudEvent = await formatter.DecodeStructuredModeMessageAsync(
             new MemoryStream(detailBytes), null, new List<CloudEventAttribute>());