From c176ca94aa0f612c3bb3856ae2acf3a399cc74a4 Mon Sep 17 00:00:00 2001
From: Kien Truong <duckientruong@gmail.com>
Date: Thu, 3 Jun 2021 11:05:02 +0700
Subject: [PATCH] Fix wrong configuration key for Compression Type

Fix #4678
---
 msa/js-executor/queue/kafkaTemplate.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/msa/js-executor/queue/kafkaTemplate.js b/msa/js-executor/queue/kafkaTemplate.js
index 2f4fd8751d..bec9a47b44 100644
--- a/msa/js-executor/queue/kafkaTemplate.js
+++ b/msa/js-executor/queue/kafkaTemplate.js
@@ -24,7 +24,7 @@ const topicProperties = config.get('kafka.topic_properties');
 const kafkaClientId = config.get('kafka.client_id');
 const acks = Number(config.get('kafka.acks'));
 const requestTimeout = Number(config.get('kafka.requestTimeout'));
-const compressionType = (config.get('kafka.requestTimeout') === "gzip") ? CompressionTypes.GZIP : CompressionTypes.None;
+const compressionType = (config.get('kafka.compression') === "gzip") ? CompressionTypes.GZIP : CompressionTypes.None;
 
 let kafkaClient;
 let kafkaAdmin;