r.id

id)在kafka集群中该值是唯一的unique如果未设置此值kafka会自动生成一个int值为了防止自动生成的值与用户设置的值冲突自动生成的逻辑是从reserved.broker.max.id

Type:

用户可以设置broker.id的最大值自动生成的broker.id从reserved.broker.max.id

1这个值开始

id高于该阈值请确保相应地增加reserved.broker.max.id

advertised.listeners

kafka会将该监听地址注册到zk上同时该地址也是客户端访问地址如果该值未设置则将同listeners与listeners不同的是advertised.listeners无法使用0.0.0.0地址

Type:

partition上需要达到多少个消息才会将这些消息持久化刷新到磁盘上

Type:

topic中的消息存放在内存中的最大时间超过这个时间就会被刷新到磁盘上如果未设置就使用

log.flush.scheduler.interval.ms

Type:

log.flush.scheduler.interval.ms

log

指定ZK服务器的连接串格式hostname:port为了保障高可用一般要指定多个地址即hostname:port,hostname1:port1,hostname2:port2也可以在配置连接串的时候指定根路径chroot

path即hostname1:port1,hostname2:port2,hostname3:port3/chroot/path

Type:

zookeeper.connection.timeout.ms

kafka连接zk的超时时长如果未设置将会使用zookeeper.session.timeout.ms值

Type:

broker的配置有三种更新模式read-only、per-broker、cluster-wide

可以针对每一个broker动态更新cluster-wide在集群范围内更新或者针对每一个broker更新只为了测试

对于read-only模式配置只能通过修改config/server.properties配置文件然后重启生效

bin/kafka-configs.sh

log.cleaner.threads对于这些被修改的per-broker模式的配置会被存储在zk

bin/kafka-configs.sh

--describe对于这些被修改的cluster-wide模式的配置会被存储在zk

在cluster-wide集群级别可配置的所有配置也可以在per-broker级别进行配置如果在不同级别定义配置值则使用以下优先顺序

Dynamic

对于一个新启动的kafka在zk中是没有per-broker和

cluster-wide

动态配置存储的所以这个时候是以配置文件为主当对某些动态配置进行配置之后对应的ZK

三、kafka-configs.sh

指定要修改的实体类型topics、clients、users、brokers、broker-loggers、ips

–entity-name

log.cleaner.threads2多个值需要用引号引住并用逗号分隔开即’k1v1,k2v2,k3[v1,v2,v3]‘

–describe