Change kafka security protocol

rage · May 23, 2024 · 34dc990 · 34dc990
1 parent c013e78
commit 34dc990
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/backend/bin/kafkaConsumer/common/createKafkaConsumer.ts b/backend/bin/kafkaConsumer/common/createKafkaConsumer.ts
@@ -47,6 +47,8 @@ export const createKafkaConsumer = ({
     offset_commit_cb: logCommit(logger),
     "enable.auto.commit": false,
     "partition.assignment.strategy": "roundrobin",
+    "security.protocol": "ssl",
+    "enable.ssl.certificate.verification": false,
   }
   if (KAFKA_DEBUG_CONTEXTS) {
     globalConfig["debug"] = KAFKA_DEBUG_CONTEXTS