xk6-kafka: Error writing messages to [topic_name] kafka.(*Client).Produce: context deadline exceeded

config.json

{
  "scenarios": {
    "constant_request_rate": {
      "executor": "constant-arrival-rate",
      "rate": 100,
      "timeUnit": "1s",
      "duration": "30s",
      "preAllocatedVUs": 100,
      "maxVUs": 200
    }
  }
}

orderPaidScenario.js

import OrderManager from '../common/orderManager/OrderManager.js'
import OrderPaidNotify from "../common/kafka/exchanges/OrderPaidNotify.js"


const testConfig = JSON.parse(open('../config/test.json'))
const orderPaidNotify = new OrderPaidNotify()


export const options = Object.assign({

}, testConfig);


export default function () {
    const order = new OrderManager().create()
    orderPaidNotify.orderPaid(order.data.order_id, order.data.items)

    console.log('OrderID: ', order.data.order_id)

}

Producer:

import { Writer, SchemaRegistry, SCHEMA_TYPE_STRING} from "k6/x/kafka";


export default class Producer {
    constructor(topic) {
        this.client = this.resolveProducerClient(topic)
        this.schemaRegistry = new SchemaRegistry()
    }

    resolveProducerClient(topic) {
        return new Writer({
            brokers: [
                'localhost:9092'
            ],
            topic: topic,
            autoCreateTopic: true,
            connectLogger: true,
            maxAttempts: 10,
            readTimeout: 1000
        })
    }

    send(message) {
        this.client.produce(this.buildMessage(message))
    }

    buildMessage(message) {
        return {
            messages:[{
                key: this.schemaRegistry.serialize({
                    data: 'k6-key-id-' + this.generateRandom(),
                    schemaType: SCHEMA_TYPE_STRING,
                }),
                value: this.schemaRegistry.serialize({
                    data: JSON.stringify(message),
                    schemaType: SCHEMA_TYPE_STRING
                })
            }]
        }
    }

    generateRandom(min = 0, max = 90000) {

        // find diff
        let difference = max - min

        // generate random number
        let rand = Math.random()

        // multiply with difference
        rand = Math.floor(rand * difference)

        // add with min value
        rand = rand + min

        return rand
    }
}

in terminal: ./k6 run scenarios/orderPaidScenario.js Output: First time its okey producing, after 5 seconds i see more error messages:

ERRO[0011] Error writing messages., OriginalError: %!w(context.deadlineExceededError={})  error="Error writing messages., OriginalError: %!w(context.deadlineExceededError={})"
ERRO[0011] GoError: Error writing messages., OriginalError: %!w(context.deadlineExceededError={})
constantat github.com/mostafa/xk6-kafka.(*Kafka).writerClass.func1 (native)
        at send (file:///Users/WebstormProjects/k6-test/common/kafka/producer.js:24:46(7))
        at produce (file:///Users/WebstormProjects/k6-test/common/kafka/exchanges/baseExchange.js:9:27(5))
        at orderPaid (file:///Users/WebstormProjects/k6-test/common/kafka/exchanges/OrderPaidNotify.js:14:21(12))
        at file:///Users/WebstormProjects/k6-test/scenarios/orderPaidScenario.js:41:22(15)