Ошибка подключения Kafka при использовании KafkaJS

Question

Я установил Kafka на свой локальный компьютер разработчика в соответствии с инструкциями здесь: https://kafka.apache.org/documentation/

Я могу создавать и использовать сообщения при запуске файлов.sh, как описано в приведенной выше ссылке.

Однако при попытке подключиться к Kafka из приложения nodejs с помощью KafkaJS на сервере Kafka регистрируется следующая ошибка:

[2020-05-15 09:07:41,210] WARN [SocketServer brokerId=0] Unexpected error from /127.0.0.1; closing connection (org.apache.kafka.common.network.Selector)
org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 369295617 larger than 104857600)
    at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:105)
    at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:448)
    at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:398)
    at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:678)
    at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:580)
    at org.apache.kafka.common.network.Selector.poll(Selector.java:485)
    at kafka.network.Processor.poll(SocketServer.scala:861)
    at kafka.network.Processor.run(SocketServer.scala:760)
    at java.lang.Thread.run(Thread.java:748)

Код производителя следующий:

const kafka = new Kafka({
    brokers: ['localhost:9092'],
    ssl: { rejectUnauthorized: false }
})

const producer = kafka.producer();

await producer.connect()

Есть идеи, почему он не работает из кода Nodejs, но работает при запуске файлов.sh?