RebalanceService run public void run() { log.info(this.getServiceName() + " service started"); while (!this.isStopped()) { this.waitForRunning(waitInterval); // 等待20s，然后超时自动释放锁执行doRebalance this.mqClientFactory.doRebalance(); // 具体逻
前言 由于业务与ELK都使用了Kafka作为消息队列，因此考虑到业务的稳定性与可用性，使用prometheus监控kafka集群。使用的监控方式为：kafka_exporter+prometheus。 提示 如果监控kafka集群的话，kafka_exporter只需在集群的一个节点安装部署即可prometheus部署在k8s之上 项目地址 ht
最近在做彩信下发，需要下发的内容是以消息的形式存放在rocektMQ,遇上彩信消息未下发的情况，需要实时去查各topic的消息积压量 1、启动时装配监控客户端的bean @Component public class MQAdminExtConfig { private static final Logger log = LoggerFactory.getLogger(MQA
