集群配置参数 - 企业云产品文档

功能概述

Kafka 集群的配置参数支持修改。当配置参数值发生变化时，系统将会重启整个 Kafka 集群，该过程中，客户端会短暂断开并重连，从而导致部分消息发送失败。企业云平台建议用户在业务低峰时执行该操作。

配置参数说明

参数说明

参数	说明
ca_sasl	是否开启 SASL。开启 SASL 后，数据会被加密传输，安全性更高。 `true` 为开启。 `false` 为关闭。
ca_cert	ca cert 文件的内容。
ca_key	ca key 文件的内容。
ca_password	ca 密码。
log.retention.bytes	Topic 每个分区的最大文件大小，单位为 `字节`，超过该大小会触发删除策略。取值范围为 `-1~1073741824000`。
log.retention.hours	消息保留时间，单位为 `小时`。取值范围为 `1~8760`。
log.segment.bytes	段文件最大值，单位为 `字节`。取值范围为 `1048576~10737418240`。
log.segment.delete.delay.ms	段文件在索引中清除后保留的时间。该参数需要设置一个值，不然最终会导致磁盘空间被写满。非 `0`。
log.roll.hours	段文件轮滚时间，单位为 `小时`。取值范围为 `1~876`。
auto.create.topics.enable	是否允许自动创建 Topic。 `true` 为允许。 `false` 为不允许。
default.replication.factor	默认副本因子值。取值范围为 `1~10`。
delete.topic.enable	是否允许使用命令行删除 Topic。 `true` 为允许。 `false` 为不允许。
offsets.topic.replication.factor	内部 offset Topic 的复制因子。如果复制因子大于集群节点数，内部创建 Topic 将会失败，直到集群大小符合这个复制因子的要求。取值范围为 `1~100`。
log.cleanup.policy	日志清理策略。 `删除` 为直接删除。 `compact` 为压缩。
log.cleaner.enable	是否开启日志压缩。 `true` 为开启。 `false` 为关闭。
compression.type	用于 Topic 的压缩策略。
message.max.bytes	消息体的最大大小，单位为 `字节`。取值范围为 `1024~1073741823`。
num.network.threads	Broker 处理网络请求的线程数。
num.io.threads	Broker 处理磁盘 IO 的线程数。取值范围为 `1~20`。
num.partitions	Topic 默认分区数。取值范围为 `1~100`。
num.recovery.threads.per.data.dir	启动时数据恢复和关闭时刷盘的线程数。
num.replica.fetchers	复制消息线程数。取值范围为 `1~10`。
queued.max.requests	等待 IO 线程处理的请求队列最大数。取值范围为 `1~5000`。
socket.receive.buffer.bytes	接收缓冲区大小。取值范围为 `1024~102400000`。
socket.send.buffer.bytes	发送缓冲区大小。取值范围为 `1024~102400000`。
unclean.leader.election.enable	是否启用不在 ISR 集合中的副本作为最后的选择，尽管这样做可能导致数据丢失。 `true` 为开启。 `false` 为关闭。
advertised.host.name	用于 Worker 连接的域名。仅 Kafka 3.1.0 - v3.0.0 之前版本支持配置该参数。
advertised.port	用于 Worker 连接的端口，默认为 `9092`。仅 Kafka 3.1.0 - v3.0.0 之前版本支持配置该参数。
kafka-manager.basicAuthentication.enabled	Kafka Manager 是否开启登录验证。 `true` 为开启。 `false` 为关闭。
kafka-manager.basicAuthentication.username	Kafka Manager 登录用户名，默认为 `admin`。
kafka-manager.basicAuthentication.password	Kafka Manager 登录密码，默认为 `password`。
kafka-manager.port	Kafka Manager 启用端口，默认为 `9000`。
zabbix.agent.enable	用于决定是否开启 Zabbix Agent。 `true` 为开启。 `false` 为关闭。
zabbix.server.ip	若开启 Zabbix Agent，则需要手动设置 Zabbix Server 的 IP 地址，默认为 `127.0.0.1`。
zabbix.agent.port	用于连接 Zabbix Agent 的端口号，若主机存在防火墙，则需要开启该端口，默认为 `10050`。取值范围为 `9000~65534`。
replica.lag.time.max.ms	Leader 将 Follower 从 ISR 中删除的时间间隔。取值范围为 `6000~99999`。
group.max.session.timeout.ms	已注册消费者最长会话超时时长。取值范围为 `0~9999999`。
group.min.session.timeout.ms	已注册消费者最短会话超时时长。取值范围为 `0~60000`。
kafka 实例使用的 Scala 版本	Kafka 实例使用的 Scala 版本。该参数不支持通过 Console 进行修改。

ca_sasl

是否开启 SASL。开启 SASL 后，数据会被加密传输，安全性更高。

true 为开启。
false 为关闭。

ca_cert

ca cert 文件的内容。

ca_key

ca key 文件的内容。

ca_password

ca 密码。

log.retention.bytes

Topic 每个分区的最大文件大小，单位为 字节，超过该大小会触发删除策略。
取值范围为 -1~1073741824000。

log.retention.hours

消息保留时间，单位为 小时。取值范围为 1~8760。

log.segment.bytes

段文件最大值，单位为 字节。取值范围为 1048576~10737418240。

log.segment.delete.delay.ms

段文件在索引中清除后保留的时间。

该参数需要设置一个值，不然最终会导致磁盘空间被写满。
非 0。

log.roll.hours

段文件轮滚时间，单位为 小时。取值范围为 1~876。

auto.create.topics.enable

是否允许自动创建 Topic。

true 为允许。
false 为不允许。

default.replication.factor

默认副本因子值。取值范围为 1~10。

delete.topic.enable

是否允许使用命令行删除 Topic。

true 为允许。
false 为不允许。

offsets.topic.replication.factor

内部 offset Topic 的复制因子。

如果复制因子大于集群节点数，内部创建 Topic 将会失败，直到集群大小符合这个复制因子的要求。
取值范围为 1~100。

log.cleanup.policy

日志清理策略。

删除 为直接删除。
compact 为压缩。

log.cleaner.enable

是否开启日志压缩。

true 为开启。
false 为关闭。

compression.type

用于 Topic 的压缩策略。

message.max.bytes

消息体的最大大小，单位为 字节。取值范围为 1024~1073741823。

num.network.threads

Broker 处理网络请求的线程数。

num.io.threads

Broker 处理磁盘 IO 的线程数。取值范围为 1~20。

num.partitions

Topic 默认分区数。取值范围为 1~100。

num.recovery.threads.per.data.dir

启动时数据恢复和关闭时刷盘的线程数。

num.replica.fetchers

复制消息线程数。取值范围为 1~10。

queued.max.requests

等待 IO 线程处理的请求队列最大数。取值范围为 1~5000。

socket.receive.buffer.bytes

接收缓冲区大小。取值范围为 1024~102400000。

socket.send.buffer.bytes

发送缓冲区大小。取值范围为 1024~102400000。

unclean.leader.election.enable

是否启用不在 ISR 集合中的副本作为最后的选择，尽管这样做可能导致数据丢失。

true 为开启。
false 为关闭。

advertised.host.name

用于 Worker 连接的域名。仅 Kafka 3.1.0 - v3.0.0 之前版本支持配置该参数。

advertised.port

用于 Worker 连接的端口，默认为 9092。仅 Kafka 3.1.0 - v3.0.0 之前版本支持配置该参数。

kafka-manager.basicAuthentication.enabled

Kafka Manager 是否开启登录验证。

true 为开启。
false 为关闭。

kafka-manager.basicAuthentication.username

Kafka Manager 登录用户名，默认为 admin。

kafka-manager.basicAuthentication.password

Kafka Manager 登录密码，默认为 password。

kafka-manager.port

Kafka Manager 启用端口，默认为 9000。

zabbix.agent.enable

用于决定是否开启 Zabbix Agent。

true 为开启。
false 为关闭。

zabbix.server.ip

若开启 Zabbix Agent，则需要手动设置 Zabbix Server 的 IP 地址，默认为 127.0.0.1。

zabbix.agent.port

用于连接 Zabbix Agent 的端口号，若主机存在防火墙，则需要开启该端口，默认为 10050。取值范围为 9000~65534。

replica.lag.time.max.ms

Leader 将 Follower 从 ISR 中删除的时间间隔。取值范围为 6000~99999。

group.max.session.timeout.ms

已注册消费者最长会话超时时长。取值范围为 0~9999999。

group.min.session.timeout.ms

已注册消费者最短会话超时时长。取值范围为 0~60000。

kafka 实例使用的 Scala 版本

Kafka 实例使用的 Scala 版本。该参数不支持通过 Console 进行修改。

修改配置参数

通过 Web 浏览器登录企业云平台的 Console。
在顶部菜单栏中选择产品与服务 > 消息队列与中间件 > Kafka 服务，进入 Kafka 管理页面。
在 Kafka 管理页面，点击目标集群 ID，进入集群详情页面。
在右侧配置参数标签页，查看 Kafka 集群当前版本所支持的参数配置项、参数描述及参数当前值。
点击修改属性，公共参数的值即进入可编辑状态，用户参考配置参数取值范围和描述，修改参数值。
确认参数信息无误后，点击保存，返回参数列表页面。