Apache Kafka

warning!

The Kafka result output is deprecated. Please use the output extension instead.

Apache Kafka is a stream-processing platform for handling real-time data.

When running a test, k6 can send the metrics in real-time to Kafka.

Instructions

You can configure the broker (or multiple ones), topic and message format directly from the command line parameter like this:

$ k6 run --out kafka=brokers=broker_host:8000,topic=k6

or if you want multiple brokers:

$ k6 --out kafka=brokers={broker1,broker2},topic=k6,format=json

You can also specify the message format k6 will use. By default, it will be the same as the JSON output, but you can also use the InfluxDB line protocol for direct "consumption" by InfluxDB:

$ k6 --out kafka=brokers=someBroker,topic=someTopic,format=influxdb

You can even modify some of the format settings such as tagsAsFields:

$ k6 --out kafka=brokers=someBroker,topic=someTopic,format=influxdb,influxdb.tagsAsFields={url,myCustomTag}

See also

• Integrating k6 with Apache Kafka