第 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: （必需）Serializer 将每个消息的密钥转换为字节，然后再发送到代理。
3: （必需）Serializer 将每个消息的值转换为字节，然后再发送到代理。
4: （可选）客户端的逻辑名称，用于日志和指标来识别请求源。
5: （可选）压缩消息的代码c，这些消息会被发送，并可能以压缩格式存储，然后在到达消费者时解压缩。压缩可用于提高吞吐量并减少存储负载，但可能不适用于压缩或解压缩成本的低延迟应用程序。