在管理控制台，支持对 Kafka 常用配置参数的管理。本小节主要介绍各配置参数的含义。

参数 取值范围 参数说明

ca_sasl

-

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

ca_cert

-

ca cert 文件的内容。

ca_key

-

ca key 文件的内容。

ca_password

-

ca 密码。

sasl.type

  • SASL-PLAINTEXT

  • SCRAM-SHA-256

  • SCRAM-SHA-512

  • SSL

SASL 协议加密算法的类型。

sasl.username

-

SASL 模式下的用户名。

sasl.password

-

SASL 模式下的用户名对应的密码。

log.retention.bytes

-1~1073741824000

Topic 每个分区的最大文件大小，单位为字节，超过该大小会触发删除策略。

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

  • true

  • false

是否允许自动创建 Topic。

default.replication.factor

1~10

默认副本因子值。

delete.topic.enable

  • true

  • false

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

offsets.topic.replication.factor

1~100

内部 offset topic 的复制因子（设定更高的确保可用性）。
如果复制因子大于集群节点数，内部创建主题自动创建将会失败，直到集群大小符合这个复制因子的要求。

log.cleanup.policy

  • 删除

  • compact

日志清理策略。

  • 删除为直接删除。

  • compact 为压缩。

log.cleaner.enable

  • true

  • false

用于是否开启日志压缩。

compression.type

-

用于主题的压缩策略。

message.max.bytes

1024~1073741823

消息体的最大大小，单位为字节。

num.network.threads

1~

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

num.io.threads

1~20

Broker 处理磁盘 IO 的线程数。

num.partitions

1~100

Topic 默认分区数。

num.recovery.threads.per.data.dir

1~

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

num.replica.fetchers

1~10

复制消息线程数。

queued.max.requests

1~5000

等待 IO 线程处理的请求队列最大数。

socket.receive.buffer.bytes

1024~102400000

接收缓冲区大小。

socket.send.buffer.bytes

1024~102400000

发送缓冲区大小。

unclean.leader.election.enable

  • true

  • false

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

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

  • true

  • false

Kafka Manager 是否开启登录验证。

kafka-manager.basicAuthentication.username

-

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

kafka-manager.basicAuthentication.password

-

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

kafka-manager.port

-

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

zabbix.agent.enable

  • true

  • false

用于决定是否开启 zabbix agent，默认为 false，不开启。

zabbix.server.ip

-

若开启 zabbix agent，则需要手动设置为您想要连接的zabbix server 的 IP 地址，默认为 127.0.0.1。

zabbix.agent.port

9000~65534

用于连接的端口号，若主机存在防火墙，则需要开启该端口，默认为 10050。

replica.lag.time.max.ms

6000~99999

leader 会将 follower 从 isr 中删除的时间间隔。

group.max.session.timeout.ms

0~9999999

已注册消费者最长会话超时时长。

group.min.session.timeout.ms

0~60000

已注册消费者最短会话超时时长。

kafka 实例使用的 Scala 版本

-

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