12.7.2. Kafka 生成器配置调整
使用基本制作者配置,以及为特定用例量身定制的可选属性。
调整配置以最大化吞吐量可能会增加延迟,反之亦然。您将需要试验并调优制作者配置,以获得所需的平衡。
12.7.2.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
- (必需)在将每条消息的密钥发送到代理前将其转换为字节。
- 3
- (必需)在将每个消息发送到代理前将每条消息的值转换为字节。
- 4
- (可选)客户端的逻辑名称,用于日志和指标来标识请求的来源。
- 5
- (可选)压缩消息的编码器(发送并可能以压缩格式存储),然后在到达消费者时解压缩。压缩对于提高吞吐量和减少存储负载非常有用,但可能不适用于低延迟应用程序,因为压缩或解压成本可能过高。