第 5 章 Kafka producer 配置调整

使用针对特定用例定制的可选属性的基本制作者配置。

调整配置以最大化吞吐量可能会增加延迟，反之亦然。您需要实验和调优制作者配置，以实现所需的平衡。

5.1. 基本制作者配置
复制链接

每个制作者都需要连接和序列化属性。通常，最好添加一个客户端 ID 进行跟踪，并使用制作者上的压缩来减少请求的批处理大小。

在基本的制作者配置中：

基本制作者配置属性

...
...

# ...
bootstrap.servers=localhost:9092


key.serializer=org.apache.kafka.common.serialization.StringSerializer


value.serializer=org.apache.kafka.common.serialization.StringSerializer


client.id=my-client


compression.type=gzip


# ...

Copy to Clipboard

Toggle word wrap

1: （必需）使用 host:port bootstrap 服务器地址为 Kafka 代理连接到 Kafka 集群。制作者使用该地址来发现和连接到集群中的所有代理。如果服务器关闭，请使用逗号分隔列表来指定两个或三个地址，但不需要提供集群中的所有代理列表。
2: （必需） Serializer 将每个消息的密钥转换为字节，然后再将其发送到代理。
3: （必需） Serializer 将每个消息的值转换为字节，然后再将其发送到代理。
4: （可选）客户端的逻辑名称，用于日志和指标来标识请求的来源。
5: （可选）压缩消息的代码c，发送信息，并可能以压缩格式存储，然后在到达消费者时解压缩。压缩对于提高吞吐量并降低存储负载很有用，但可能不适用于低延迟应用程序（压缩成本或解压缩可能非常禁止）。