Making Sonar Happy

leandrodamascena · leandrodamascena · commit ab0842d0efc2 · 2025-06-30T14:32:59.000+01:00
diff --git a/examples/kafka/consumer/src/working_with_large_messages.py b/examples/kafka/consumer/src/working_with_large_messages.py
@@ -14,7 +14,7 @@ def process_standard_message(message):
 
 def process_catalog_from_s3(bucket, key):
     # Simulate processing logic
-    return {"product_count": 1000}
+    return {"bucket": bucket, "key": key}
 
 
 @kafka_consumer(schema_config=schema_config)
diff --git a/examples/kafka/consumer/src/working_with_schema_errors.py b/examples/kafka/consumer/src/working_with_schema_errors.py
@@ -15,7 +15,7 @@
 
 def process_order(order):
     # Simulate processing logic
-    return "OK"
+    return order
 
 
 def send_to_dlq(record):
