'code;

.dapr/components/kafka-pubsub.yaml

@@ -6,11 +6,36 @@ spec:
   type: pubsub.kafka
   version: v1
   metadata:
+
+  # Kafka broker from Confluent Cloud
   - name: brokers
-    value: "localhost:9092"  # Update this for your Kafka broker address
+    value: "pkc-921jm.us-east-2.aws.confluent.cloud:9092"
+
+  # Consumer group (can be anything)
   - name: consumerGroup
-    value: "audit-service-group"
-  - name: clientID
-    value: "audit-service"
-  - name: authType
-    value: "none"
+    value: "taskflow-group"
+
+  # Enable auth (REQUIRED for Confluent)
+  - name: authRequired
+    value: "true"
+
+  # SASL credentials
+  - name: saslUsername
+    value: "2UTIBYE7BJQMGC3D"
+
+  - name: saslPassword
+    value: "cfltBZAije3bsijZKl01xleqphU5argnDcsKEZlG10Xwmf4aXhsJUXKt3O9lQwEA"
+
+  # Confluent Cloud settings
+  - name: saslMechanism
+    value: "PLAIN"
+
+  - name: securityProtocol
+    value: "SASL_SSL"
+
+  # Optional tuning
+  - name: disableTls
+    value: "false"
+
+  - name: autoOffsetReset
+    value: "latest"