第 4 章 Kafka 使用者配置调整

使用基本消费者配置，以及专为特定用例量身定制的可选属性。

在调整您的消费者时，您的主要关注将确保它们与最接近的数据量保持一致。与生成者调优一样，准备好进行增量更改，直到消费者按预期运行为止。

4.1. 基本消费者配置
复制链接

每个消费者都需要 connection 和 deserializer 属性。通常，为跟踪添加客户端 ID 是不错的做法。

在消费者配置中，无论后续配置是什么：

基本消费者配置属性

...
...

# ...
bootstrap.servers=localhost:9092


key.deserializer=org.apache.kafka.common.serialization.StringDeserializer


value.deserializer=org.apache.kafka.common.serialization.StringDeserializer


client.id=my-client


group.id=my-group-id


# ...

Copy to Clipboard

Toggle word wrap

1: （必需）使用 Kafka 代理的 host:port bootstrap 服务器地址来连接 Kafka 集群的消费者。消费者使用地址来发现并连接到集群中的所有代理。在服务器停机时，使用逗号分隔的列表指定两个或多个地址，但不需要提供集群中的所有代理列表。如果您使用 loadbalancer 服务公开 Kafka 集群，则只需要该服务的地址，因为可用性是由 loadbalancer 处理的。
2: （必需）将从 Kafka 代理获取的字节转换为消息键的反序列化器。
3: （必需）将从 Kafka 代理获取的字节转换为消息值的反序列化器。
4: （可选）客户端的逻辑名称，用于日志和指标来标识请求的来源。id 也可以根据处理时间配额来节流消费者。
5: （条件）需要组 id 才能加入消费者组。