为方便用户更好的配置集群，现对各参数含义说明如下。

参数 说明

sasl.type

SASL 的类型，无 表示不开启。开启 SASL 后，数据会被加密传输，安全性更高。可选加密类型如下。

  • SASL-PLAINTEXT 、SCRAM-SHA-256 以及 SCRAM-SHA-512 类型，需同步设置以下参数。

    • sasl.username：SASL 模式下的用户名。

    • sasl.password：client 和 broker 之间通信的密码。

  • SSL 类型，需同步设置以下参数。

    • ca_cert：ca cert 文件的内容。

    • ca_key：ca key 文件的内容。

    • sasl.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 进行修改。