kafka.to() 函数
kafka.to() 将数据发送到 Apache Kafka 代理。
函数类型签名
(
<-tables: stream[A],
brokers: [string],
topic: string,
?balancer: string,
?name: string,
?nameColumn: string,
?tagColumns: [string],
?timeColumn: string,
?valueColumns: [string],
) => stream[A] where A: Record
有关更多信息，请参见 Function type signatures。
参数
经纪人
(必填) 要发送数据的Kafka代理列表。
主题
(必需) 要发送数据的Kafka主题。
负载均衡器
Kafka 负载均衡策略。默认是 hash。
负载均衡策略决定了消息如何被路由到Kafka集群上可用的分区。以下策略可用：
- hash: 使用组键的哈希值来确定将消息路由到哪个Kafka分区。这确保了来自表中行生成的消息被路由到同一个分区。
- 轮询: 在所有可用分区之间均匀分配消息。
- least-bytes: 将消息路由到接收数据最少的分区。
名称
Kafka指标名称。 默认值为nameColumn的值。
名称列
用于作为Kafka指标名称的列。 默认值是 _measurement。
时间列
时间列。默认为 _time。
tagColumns
输入数据中标签列的列表。
值列
输入数据中值列的列表。默认是 ["_value"]。
表格
输入数据。默认是管道转发数据 (<-).
示例
将数据发送到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"],
)