第 5 章 Kafka producer 配置调整

使用基本制作者配置，以及专为特定用例量身定制的可选属性。

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

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

每个制作者都需要 connection 和 serializer 属性。通常，为跟踪添加客户端 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: （必需）使用 Kafka 代理的 host:port bootstrap 服务器地址来连接 Kafka 集群的制作者。制作者使用地址来发现并连接到集群中的所有代理。在服务器停机时，使用逗号分隔的列表指定两个或多个地址，但不需要提供集群中的所有代理列表。
2: （必需）在发送到代理前，将每个消息的密钥转换为字节的序列化器。
3: （必需）在发送到代理前将每个消息的值转换为字节的序列化器。
4: （可选）客户端的逻辑名称，用于日志和指标来标识请求的来源。
5: （可选）压缩消息的 codec，它们以压缩格式发送并存储，然后在到达消费者时解压缩。压缩可用于提高吞吐量并减少存储负载，但可能不适用于低延迟应用程序，因为压缩成本可能会被压缩或解压缩。