classdesc
Writer writes messages to Kafka.
example
// In init context
const writer = new Writer({
brokers: ["localhost:9092"],
topic: "my-topic",
autoCreateTopic: true,
});
// In VU code (default function)
writer.produce({
messages: [
{
key: "key",
value: "value",
},
],
});
// In teardown function
writer.close();
• new Writer(writerConfig
)
Name | Type | Description |
---|---|---|
writerConfig |
WriterConfig |
Writer configuration. |
▸ close(): void
destructor
description
Close the writer.
void
- Nothing.
▸ produce(produceConfig
): void
method
Write messages to Kafka.
Name | Type | Description |
---|---|---|
produceConfig |
ProduceConfig |
Produce configuration. |
void
- Nothing.