Documentation function sends data to Apache Kafka brokers.

Function type signature
    <-tables: stream[A],
    brokers: [string],
    topic: string,
    ?balancer: string,
    ?name: string,
    ?nameColumn: string,
    ?tagColumns: [string],
    ?timeColumn: string,
    ?valueColumns: [string],
) => stream[A] where A: Record
For more information, see Function type signatures.



(Required) List of Kafka brokers to send data to.


(Required) Kafka topic to send data to.


Kafka load balancing strategy. Default is hash.

The load balancing strategy determines how messages are routed to partitions available on a Kafka cluster. The following strategies are available:

  • hash: Uses a hash of the group key to determine which Kafka partition to route messages to. This ensures that messages generated from rows in the table are routed to the same partition.
  • round-robin: Equally distributes messages across all available partitions.
  • least-bytes: Routes messages to the partition that has received the least amount of data.


Kafka metric name. Default is the value of the nameColumn.


Column to use as the Kafka metric name. Default is _measurement.


Time column. Default is _time.


List of tag columns in input data.


List of value columns in input data. Default is ["_value"].


Input data. Default is piped-forward data (<-).


Send data to Kafka

import "kafka"
import "sampledata"
        brokers: [""],
        topic: "example-topic",
        name: "example-metric-name",
        tagColumns: ["tag"],

Was this page helpful?

Thank you for your feedback!

Linux Package Signing Key Rotation

All signed InfluxData Linux packages have been resigned with an updated key. If using Linux, you may need to update your package configuration to continue to download and verify InfluxData software packages.

For more information, see the Linux Package Signing Key Rotation blog post.

State of the InfluxDB Cloud (IOx) documentation

The new documentation for InfluxDB Cloud backed by InfluxDB IOx is a work in progress. We are adding new information and content almost daily. Thank you for your patience!

If there is specific information you’re looking for, please submit a documentation issue.