附录 C. 使用者配置参数

PDF

key.deserializer

type: class
Importance: high

实现 org.apache.kafka.common.serialization.Deserializer 接口的密钥的 deserializer 类。

value.deserializer

type: class
Importance: high

实现 org.apache.kafka.common.serialization.Deserializer 接口的值的 deserializer 类。

bootstrap.servers

type: list
Default: ""
Valid Values: non-null string
Importance: high

用于建立与 Kafka 集群的初始连接的主机/端口对列表。客户端将使用与此处为 bootstrapping 指定的服务器一样的所有服务器，此列表只会影响用于发现整套服务器的初始主机。这个列表应该采用 host1:port1,host2:port2,… 格式。由于这些服务器仅用于初始连接来发现完整的集群成员身份（可能会动态更改），因此该列表不需要包含完整的服务器集合（尽管，如果服务器停机，您可能希望多台服务器）。

fetch.min.bytes

type: int
Default: 1
Valid Values: [0,…]
Importance: high

服务器为获取请求返回的最小数据量。如果数据不足，请求将等待大量数据积累，然后再回答请求。1 字节的默认设置意味着，一旦有单个数据可用或获取请求超时等待数据到达时，便会立即回答获取请求。将它设置为大于 1 的内容将导致服务器等待更大数量的数据积累，从而以一些额外的延迟为代价提高服务器吞吐量。

group.id

type: string
Default: null
Importance: high

个唯一字符串，用于标识该消费者所属的消费者组。如果消费者使用 subscribe(topic) 或基于 Kafka 的偏移管理策略使用组管理功能，则需要此属性。

heartbeat.interval.ms

type: int
Default: 3000（3 秒）
Importance: high

在使用 Kafka 的组管理设施时，心跳与消费者协调员之间的预计时间。心跳用于确保消费者的会话保持活跃，并促进新消费者加入或离开组时的重新平衡。该值必须小于 session.timeout.ms，但通常应不高于该值的 1/3。它甚至可以调整，以控制正常重新平衡的预期时间。

max.partition.fetch.bytes

type: int
Default: 1048576(1 mebibyte)
Valid Values: [0,…]
Importance: high

服务器将返回的每分区的最大数据量。记录由使用者批量获取。如果获取的第一个非空分区中的第一个记录批处理大于此限制，则仍会返回批处理以确保消费者能够进行进度。代理接受的最大记录批处理大小通过 message.max.bytes (broker config)或 max.message.bytes （主题配置）定义。请参阅 fetch.max.bytes 以限制消费者请求大小。

session.timeout.ms

type: int
Default: 10000（10 秒）
Importance: high

在使用 Kafka 的组管理功能时用于检测客户端故障的超时时间。客户端会定期发送心跳，以向代理表明其存活度。如果代理没有在此会话超时前收到心跳，代理会从组中删除此客户端并启动重新平衡。请注意，该值必须处于允许范围内，如 group.min.session.timeout.ms 和 group.max.session.timeout.ms 代理配置中所配置。

ssl.key.password