Kafka errors NotLeaderForPartitionException,

增大session的timeout时间 
可有效缓解(但系统依旧”卡顿“,影响性能),将初始值更改为30s,在 server.properties 中:


zookeeper.session.timeout.ms=30000


增加磁盘IO处理线程数(具体数值请根据实际情况) 
在 server.properties 中:
num.io.threads=12


增加 log 数据盘数(具体数值请根据实际情况) 
在每台机器上多挂载几个盘,更改 kafka 的 server.properties 参数:
log.dirs=/mnt/datadir1/kafka-logs-0,/mnt/datadir2/kafka-logs-0,/mnt/datadir3/kafka-logs-0

发布了185 篇原创文章 · 获赞 312 · 访问量 56万+

猜你喜欢

转载自blog.csdn.net/shujuelin/article/details/100681197
今日推荐