第 5 章 Kafka 制作者配置调整

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

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

5.1. 基本制作者配置

每个制作者都需要连接和序列化属性。通常,为跟踪添加客户端 ID,并在生成者上使用压缩来减少请求中的批处理大小。

在基本制作者配置中:

  • 分区中的信息顺序不能保证。
  • 确认到达代理的消息不能保证持久性。

基本制作者配置属性

# ...
bootstrap.servers=localhost:9092 1
key.serializer=org.apache.kafka.common.serialization.StringSerializer 2
value.serializer=org.apache.kafka.common.serialization.StringSerializer 3
client.id=my-client 4
compression.type=gzip 5
# ...

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