第 5 章 Kafka 制作者配置调整

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

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

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

每个制作者都需要连接和序列化属性。通常，为跟踪添加客户端 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


# ...

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