diff --git a/msa/js-executor/queue/kafkaTemplate.js b/msa/js-executor/queue/kafkaTemplate.js
index 656779869d..1d1ad75318 100644
--- a/msa/js-executor/queue/kafkaTemplate.js
+++ b/msa/js-executor/queue/kafkaTemplate.js
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-const {logLevel, Kafka, CompressionTypes} = require('kafkajs');
+const {logLevel, Kafka, CompressionTypes, Partitioners} = require('kafkajs');
 
 const config = require('config'),
     JsInvokeMessageProcessor = require('../api/jsInvokeMessageProcessor'),
@@ -159,7 +159,7 @@ async function sendMessagesAsBatch(isImmediately) {
         }
 
         consumer = kafkaClient.consumer({groupId: 'js-executor-group'});
-        producer = kafkaClient.producer();
+        producer = kafkaClient.producer({ createPartitioner: Partitioners.DefaultPartitioner });
 
 /*
         //producer event instrumentation to debug