Error to connect kafka when I change version to v0.9.0

[rosicleiafrasson]

My script worked in version v0.8.0. After I switch to version 0.9.0 I started getting this error:

Failed to write message: read tcp ip: read: connection reset by peerFailed to write message.

import { check } from "k6";
import {
    writer,
    produceWithConfiguration,
    createTopic,
} from "k6/x/kafka"; 
import http from 'k6/http';
import encoding from 'k6/encoding';

const bootstrapServers = ["xxx:9092"];
const topic = "payin";

const auth = JSON.stringify({
    username: "xxx",
    password: "xxx",
    algorithm: "SHA512",
});

const producer = writer(bootstrapServers, topic, auth);

var configuration = JSON.stringify({
    producer: {
        keySerializer: "io.confluent.kafka.serializers.KafkaAvroSerializer",
        valueSerializer: "io.confluent.kafka.serializers.KafkaAvroSerializer",
    },
    schemaRegistry: {
        url: "xxxx",
        basicAuth: {
            credentialsSource: "USER_INFO",
            userInfo: "xxx:xxx",
        },
    },
});

export default function () {

    const credentials = `xxx:xxx`;
    const encodedCredentials = encoding.b64encode(credentials);
    const options = {
        headers: {
        Authorization: `Basic ${encodedCredentials}`,
        },
    };

const result = http.get('xxxx', options)
const schema = JSON.parse(result.body).schema

let messages = [
    {
        value: JSON.stringify({
            "status": "PROPOSED"
        }),
    },
];

let error = produceWithConfiguration(
    producer,
    messages,
    configuration,
    null,
    schema
);

check(error, {
    "is sent": (err) => err == undefined,
});

}

[eabreusantos]

I'm having the same behavior.

[mostafa]

@rosicleiafrasson @eabreusantos
The APIs are slightly changed. Please check the scripts in the v0.9.0 tree. Also, I'm going to release a new version soon, which includes lots of changes.

[mostafa]

@rosicleiafrasson @eabreusantos
Any updates?

[rosicleiafrasson]

Yes, I analyzed the way authentication in the v0.9.0 scripts. But the way is the same. I still have the same problem.

[mostafa]

@rosicleiafrasson @eabreusantos
Please update your scripts according to the latest changes to the API, as shown in this script and then build the latest main branch and test it to see if it works.

[mostafa]

Released in v0.11.0.