fix event bus benthos

formancehq · Feb 28, 2024 · 0a7d33f · 0a7d33f
1 parent 3c9293d
commit 0a7d33f
Showing 1 changed file with 15 additions and 13 deletions.
diff --git a/ee/search/benthos/templates/event_bus.yaml b/ee/search/benthos/templates/event_bus.yaml
@@ -14,21 +14,23 @@ mapping: |
       "topics": [ env("TOPIC_PREFIX") + this.topic ],
       "consumer_group": this.consumer_group,
       "checkpoint_limit": 1024,
-      "sasl": {
-        "mechanism": env("KAFKA_SASL_MECHANISM"),
-        "password": env("KAFKA_SASL_PASSWORD"),
-        "username": env("KAFKA_SASL_USERNAME"),
-        "aws": {
-          "region": env("AWS_REGION"),
-          "credentials": {
-            "profile": env("AWS_PROFILE"),
-            "id": env("AWS_ACCESS_KEY_ID"),
-            "secret": env("AWS_SECRET_ACCESS_KEY"),
-            "token": env("AWS_SESSION_TOKEN"),
-            "role": env("AWS_ROLE_ARN")
+      "sasl": [
+        {
+          "mechanism": env("KAFKA_SASL_MECHANISM"),
+          "password": env("KAFKA_SASL_PASSWORD"),
+          "username": env("KAFKA_SASL_USERNAME"),
+          "aws": {
+            "region": env("AWS_REGION"),
+            "credentials": {
+              "profile": env("AWS_PROFILE"),
+              "id": env("AWS_ACCESS_KEY_ID"),
+              "secret": env("AWS_SECRET_ACCESS_KEY"),
+              "token": env("AWS_SESSION_TOKEN"),
+              "role": env("AWS_ROLE_ARN")
+            }
           }
         }
-      },
+      ],
       "tls": {
         "enabled": env("KAFKA_TLS_ENABLED") == "true"
       }