操作场景
天翼云分布式消息服务Kafka为实例、主题、消费组的几个常用配置提供了默认值,在实例开通时默认配置,并支持在控制台手动修改,您可以根据具体的业务需求,自行修改。这几种常用的配置参数,根据是否需要重启Kafka实例,可以分为动态参数和静态参数:
- 动态参数:修改成功后,无需重启实例,立即生效
- 静态参数:修改成功后,只有重启实例才能生效
操作前提
- 已开通天翼云Kafka实例,实例的运行状态为“运行中”
- Kafka 实例是天翼云4.0资源池实例,目前4.0资源池包括:华东1、上海36、华北2、长沙42、武汉41、西安7、杭州7、青岛20、西南1、西南2、广州4、郑州5、华南2等
操作步骤
- 登陆管理控制台
- 进入Kafka管理控制台
- 在实例列表页的操作列,目标实例行点击“管理”
- 点击“配置参数”,在待修改参数所在行,单击“编辑”,修改配置参数。
- 单击“保存”,完成参数的修改。
参数说明
动态参数
参数 |
参数说明 |
参数范围 |
默认值 |
log.flush.interval.messages |
消息条数刷盘阈值,当实例 broker 接收的消息条数达到阈值时,将触发消息刷盘 |
1~9223372036854775807 |
9223372036854775807 |
min.insync.replicas |
当 producer 将 acks 设置为 “all” (或“-1”) 时,此配置指定必须确认写入才能被认为成功的副本的最小数量 |
1~3 |
1 |
message.max.bytes |
kafka 允许的 topic 最大单条消息大小(单位:字节) |
0~10485760 |
10485760 |
max.connections.per.ip |
每个 ip 允许的最大连接数。超过此连接数的连接请求将被丢弃 |
100~20000 |
1000
|
unclean.leader.election.enable |
是否能够使不在 ISR 中 replicas 设置用来作为 leader |
true,false |
false |
静态参数
参数 |
参数说明 |
参数范围 |
默认值 |
connections.max.idle.ms |
连接空闲超时:服务器 socket 处理线程空闲超时关闭时间 |
5000~600000 |
600000 |
log.retention.hours |
日志删除的时间阈值(小时为单位) |
1~168 |
72 |
group.max.session.timeout.ms |
consumer 允许的最大会话超时时间。超时时间越长,consumer 就能在心跳探测周期内有更多时间处理消息,但也会使故障检测花费更长时间 |
6000~1800000 |
1800000 |
auto.create.topics.enable |
是否开启创建主题功能。 |
true,false |
false |
default.replication.factor |
自动创建 topic 时的默认副本个数。 |
1~3 |
3 |
offsets.retention.minutes |
消费位点保留时间是消费位点最大保留时间,从提交消费位点的时间开始计算,超过该时间的消费位点将被删除。group 每次向一个 topic 分区提交一次消费位点时,该消费位点的保留时间将会被重置为0 |
1440~30240 |
30240 |
num.partitions |
自动创建 topic 时的默认分区数。 |
1~100 |
3 |
group.min.session.timeout.ms |
consumer 允许的最小会话超时时间。超时时间越短,consumer 的心跳探测越频繁,可以使故障检测更快,但会导致 broker 被抢占更多的资源 |
6000~300000 |
6000 |