Change kafka security protocol

nygrenh · nygrenh · commit 34dc990c432f · 2024-05-23T12:53:23.000+03:00
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

Original file line number	Diff line number	Diff line change
`@@ -47,6 +47,8 @@ export const createKafkaConsumer = ({`
`47`	`47`	`offset_commit_cb: logCommit(logger),`
`48`	`48`	`"enable.auto.commit": false,`
`49`	`49`	`"partition.assignment.strategy": "roundrobin",`
	`50`	`+ "security.protocol": "ssl",`
	`51`	`+ "enable.ssl.certificate.verification": false,`
`50`	`52`	`}`
`51`	`53`	`if (KAFKA_DEBUG_CONTEXTS) {`
`52`	`54`	`globalConfig["debug"] = KAFKA_DEBUG_CONTEXTS`