kafka.to() 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
(Required) List of Kafka brokers to send data to.
(Required) Kafka topic to send data to.
Kafka load balancing strategy. Default is
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
Column to use as the Kafka metric name.
Time column. Default is
List of tag columns in input data.
List of value columns in input data. Default is
Input data. Default is piped-forward data (
Send data to Kafka
import "kafka" import "sampledata" sampledata.int() |> kafka.to( brokers: ["http://127.0.0.1:9092"], topic: "example-topic", name: "example-metric-name", tagColumns: ["tag"], )
Was this page helpful?
Thank you for your feedback!
Support and feedback
Thank you for being part of our community! We welcome and encourage your feedback and bug reports for Flux and this documentation. To find support, use the following resources:
Customers with an annual or support contract can contact InfluxData Support.