Skip to content

Commit 5cbd1f5

Browse files
author
Vikas Agarwal
committed
trying fix for kafka connection error
1 parent 492a5c9 commit 5cbd1f5

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/services/kafkaConsumer.js

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,9 +19,12 @@ export default async function startKafkaConsumer(handlers, app, logger) {
1919
options.connectionString = kafkaConfig.get('url');
2020
}
2121
if (kafkaConfig.has('clientCert') && kafkaConfig.has('clientCertKey')) {
22+
23+
const clientCert = kafkaConfig.get('clientCert').replace('\\n', '\n');
24+
const clientCertKey = kafkaConfig.has('clientCertKey').replace('\\n', '\n');
2225
options.ssl = {
23-
cert: kafkaConfig.get('clientCert'),
24-
key: kafkaConfig.has('clientCertKey'),
26+
cert: clientCert,
27+
key: clientCertKey,
2528
};
2629
}
2730

0 commit comments

Comments
 (0)