Better handling of Kafka URL format

jmgasper · jmgasper · commit 89b4d084ebfd · 2024-08-14T13:51:57.000+10:00
diff --git a/src/init.js b/src/init.js
@@ -16,7 +16,7 @@ async function configureKafkaConsumer (handlers) {
   // create group consumer
   let brokers = ['']
   if (config.KAFKA_URL.startsWith('ssl://')) {
-    brokers = config.KAFKA_URL.split('ssl://')[1].split(',')
+    brokers = _.replace(config.KAFKA_URL, 'ssl://', '').split(',')
   } else {
     brokers = config.KAFKA_URL.split(',')
   }

Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@ async function configureKafkaConsumer (handlers) {`
`16`	`16`	`// create group consumer`
`17`	`17`	`let brokers = ['']`
`18`	`18`	`if (config.KAFKA_URL.startsWith('ssl://')) {`
`19`		`- brokers = config.KAFKA_URL.split('ssl://')[1].split(',')`
	`19`	`+ brokers = _.replace(config.KAFKA_URL, 'ssl://', '').split(',')`
`20`	`20`	`} else {`
`21`	`21`	`brokers = config.KAFKA_URL.split(',')`
`22`	`22`	`}`