test_timeout.js

/*

This is a k6 test script that imports the xk6-kafka and


*/

import { check } from "k6";
// import * as kafka from "k6/x/kafka";
import { Reader, Connection } from "k6/x/kafka"; // import kafka extension

// Prints module-level constants
// console.log(kafka);

const brokers = ["localhost:9092"];
const topic = "xk6_kafka_json_topic";

const reader = new Reader({
  brokers: brokers,
  topic: topic,
  maxWait: "5s",
});

const connection = new Connection({
  address: brokers[0],
});

if (__VU === 0) {
  connection.createTopic({ topic: topic });
}

export const options = {
  thresholds: {
    // Base thresholds to see if the writer or reader is working
    kafka_writer_error_count: ["count == 0"],
    kafka_reader_error_count: ["count == 0"],
  },
  duration: "11s",
};

export default function () {
  // Read 10 messages only
  let messages = reader.consume({ limit: 10 });

  console.log("continuing execution");

  check(messages, {
    "10 messages are received": (messages) => messages.length === 10,
  });
}

export function teardown(data) {
  if (__VU === 0) {
    // Delete the topic
    connection.deleteTopic(topic);
  }
  reader.close();
  connection.close();
}