: 应试是很久没更新了;
KafkaManager: 用于管理还可以, 监控报警的话需要自己添加少量接口实现;
Burrow: 个人觉得是目前为止最好用的lag监控报警工具;
Burrow 功能简介...Burrow的github主页已经对其从编译到配置使用作了很好的说明, 这里不累述;
Burrow用Golang写成, 代码不多, 很容易读, 扩展性也很多;
使用Burrow作监控, 不需要预先设置...Burrow 使用中遇到的问题:
Burrow只能监控在Burrow运行后提交过offset的group, 因为在通过sarama消费__consumer_offsets这个topic来获取committed...:fatal error: concurrent map read and map write, 查了下是在evaluateGroup中对clusterMap.broker的读操作和在addBrokerOffset...中对其写操作引发, 加锁吧~,可以拷贝一份clusterMap.broker来读.