配置参数

 

参数介绍

更新时间 2023-09-06

在管理控制台,支持对 Kafka 常用配置参数的管理。

本小节主要介绍各配置参数的含义。

支持配置的参数

参数 取值范围 参数说明
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
  • delete
  • compact
  • 日志清理策略。delete 为直接删除;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 连接的域名。
    advertised.port - 用于 worker 连接的端口,默认为 9092
    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 版本, 默认为 2.11,推荐使用 2.12
    该参数不支持通过界面进行修改。
    这篇文档解决了您的问题吗?
    0
    0