From 13f2db2e177cf2d90c5401eff5f3e33f4c921482 Mon Sep 17 00:00:00 2001
From: Henrik Nygren <nygrenh@gmail.com>
Date: Thu, 23 May 2024 11:38:54 +0300
Subject: [PATCH] Change kafka security protocol

---
 backend/bin/kafkaConsumer/common/createKafkaConsumer.ts | 1 +
 1 file changed, 1 insertion(+)

diff --git a/backend/bin/kafkaConsumer/common/createKafkaConsumer.ts b/backend/bin/kafkaConsumer/common/createKafkaConsumer.ts
index dc5e25d0a..d0b905b5a 100644
--- a/backend/bin/kafkaConsumer/common/createKafkaConsumer.ts
+++ b/backend/bin/kafkaConsumer/common/createKafkaConsumer.ts
@@ -47,6 +47,7 @@ export const createKafkaConsumer = ({
     offset_commit_cb: logCommit(logger),
     "enable.auto.commit": false,
     "partition.assignment.strategy": "roundrobin",
+    "security.protocol": "ssl",
   }
   if (KAFKA_DEBUG_CONTEXTS) {
     globalConfig["debug"] = KAFKA_DEBUG_CONTEXTS