From 6a986b17f965986f899c8865f216bf4cef83c4ed Mon Sep 17 00:00:00 2001 From: AndreMaz Date: Wed, 25 Jan 2023 11:14:10 +0000 Subject: [PATCH] fix name of the var --- msa/js-executor/queue/kafkaTemplate.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/msa/js-executor/queue/kafkaTemplate.ts b/msa/js-executor/queue/kafkaTemplate.ts index 9b089dbb57..b1b2493015 100644 --- a/msa/js-executor/queue/kafkaTemplate.ts +++ b/msa/js-executor/queue/kafkaTemplate.ts @@ -42,7 +42,7 @@ export class KafkaTemplate implements IQueue { private maxBatchSize = Number(config.get('kafka.batch_size')); private linger = Number(config.get('kafka.linger_ms')); private requestTimeout = Number(config.get('kafka.requestTimeout')); - private connectionTimeout = Number(config.get('kafka.connection_timeout_ms')); + private connectionTimeout = Number(config.get('kafka.connectionTimeout')); private compressionType = (config.get('kafka.compression') === "gzip") ? CompressionTypes.GZIP : CompressionTypes.None; private partitionsConsumedConcurrently = Number(config.get('kafka.partitions_consumed_concurrently'));