KafkaJSConnectionClosedError: Closed connection

[kante-srikanth]

Describe the bug
Hi,

I am trying to use KafkaJS to produce some messages locally and consume them. With the given config in the documentation I can connect to the producer but when I am trying to send the message I am getting a KafkaNonJSRetriableError caused by KafkaJSConnectionClosedError before sending the message.

config

const kafka = new Kafka({clientId: 'client', brokers: brokers});
const producer = kafka.producer();
await producer.connect();
producer.send({topic: "TOPIC_NAME", messages: [{value: 'something', partition: 1}]})

Any help would be much-appreciated
version: 2.2.4

Note: I am trying this in Office NDS