#broker.id 属性在 kafka 集群中必须要是唯一
broker.id=0
#kafka 部署的机器 ip 和提供服务的端口号(只需要内网访问,外网访问时需要增配
advertised.listeners)
listeners=PLAINTEXT://192.168.0.219:19092
#broker 处理消息的最大线程数,一般情况下不需要去修改
num.network.threads=3
#broker 处理磁盘 IO 的线程数,数值应该大于你的硬盘数
num.io.threads=8
#socket 的发送缓冲区,socket 的调优参数 SO_SNDBUFF
socket.send.buffer.bytes=102400
#socket 的接受缓冲区,socket 的调优参数 SO_RCVBUFF
socket.receive.buffer.bytes=102400
#socket 请求的最大数值,防止 serverOOM,message.max.bytes 必然要小于
socket.request.max.bytes,会被 topic 创建时的指定参数覆盖
socket.request.max.bytes=104857600
#kafka 数据的存放地址,多个地址的话用逗号分割
log.dirs=/data/server/elk/kafka/kafka/log
#每个 topic 的分区个数,若是在 topic 创建时候没有指定的话会被 topic 创建时的指定参数
覆盖
num.partitions=1
num.recovery.threads.per.data.dir=1
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
#数据存储的最大时间
log.retention.hours=168
#topic 的分区是以一堆 segment 文件存储的,这个控制每个 segment 的大小,会被 topic 创
建时的指定参数覆盖
log.segment.bytes=1073741824
#文件大小检查的周期时间
log.retention.check.interval.ms=300000
#zookeeper 地址
zookeeper.connect=192.168.0.219:2181
#ZooKeeper 的连接超时时间
zookeeper.connection.timeout.ms=18000
#空消费组延时 rebalance
group.initial.rebalance.delay.ms=0