第 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,这些消息以压缩格式存储,然后在到达消费者时进行解压缩。压缩可用于提高吞吐量和降低存储负载,但可能不适用于压缩或解压缩成本的低延迟应用程序。