Comments (7)
看下 metaserver 的日志和数据库,看看里面有没有 broker 信息。
from qmq.
看下 metaserver 的日志和数据库,看看里面有没有 broker 信息。
broker表里有记录,broker_group表是空的。
日志的话,我贴一下metaserver.out的内容(只截取部分,内容有点多)
[2021-08-09 15:47:57 INFO qunar.tc.qmq.meta.processor.BrokerRegisterProcessor] broker register request received. request: BrokerRegisterRequest{groupName='mytestbroker', brokerRole=0, brokerState=4, requestType=1, brokerAddress='10.37.129.2:20881'}
[2021-08-09 15:47:57 INFO qunar.tc.qmq.meta.processor.BrokerRegisterProcessor] Broker heartbeat response, request:BrokerRegisterRequest{groupName='mytestbroker', brokerRole=0, brokerState=4, requestType=1, brokerAddress='10.37.129.2:20881'}
[2021-08-09 15:48:02 INFO qunar.tc.qmq.meta.cache.CachedMetaInfoManager] refresh meta info
[2021-08-09 15:48:07 INFO qunar.tc.qmq.meta.cache.CachedMetaInfoManager] refresh meta info
[2021-08-09 15:48:07 INFO qunar.tc.qmq.meta.processor.BrokerRegisterProcessor] broker register request received. request: BrokerRegisterRequest{groupName='mytestbroker', brokerRole=0, brokerState=4, requestType=1, brokerAddress='10.37.129.2:20881'}
[2021-08-09 15:48:07 INFO qunar.tc.qmq.meta.processor.BrokerRegisterProcessor] Broker heartbeat response, request:BrokerRegisterRequest{groupName='mytestbroker', brokerRole=0, brokerState=4, requestType=1, brokerAddress='10.37.129.2:20881'}
[2021-08-09 15:48:12 INFO qunar.tc.qmq.meta.cache.CachedMetaInfoManager] refresh meta info
[2021-08-09 15:48:13 INFO qunar.tc.qmq.netty.ConnectionHandler] [name: meta] client /10.37.129.2:63863 connected
[2021-08-09 15:48:13 INFO qunar.tc.qmq.concurrent.ActorSystem] create actorSystem: client_register_order.changed
[2021-08-09 15:48:13 INFO qunar.tc.qmq.concurrent.ActorSystem] create actorSystem: client_register_%RETRY%order.changed%ordercenter
[2021-08-09 15:48:13 ERROR qunar.tc.qmq.meta.route.impl.DefaultSubjectRouter] find subject route error
java.lang.NullPointerException: null
at com.google.common.collect.ImmutableList.copyOf(ImmutableList.java:258)
at qunar.tc.qmq.meta.cache.CachedMetaInfoManager.getAllDefaultTagBrokerGroupNames(CachedMetaInfoManager.java:118)
at qunar.tc.qmq.meta.route.impl.DefaultSubjectRouter.findAvailableBrokerGroupNames(DefaultSubjectRouter.java:168)
at qunar.tc.qmq.meta.route.impl.DefaultSubjectRouter.assignNewBrokers(DefaultSubjectRouter.java:100)
at qunar.tc.qmq.meta.route.impl.DefaultSubjectRouter.doRoute(DefaultSubjectRouter.java:79)
at qunar.tc.qmq.meta.route.impl.DefaultSubjectRouter.route(DefaultSubjectRouter.java:64)
at qunar.tc.qmq.meta.route.impl.DelayRouter.route(DelayRouter.java:48)
at qunar.tc.qmq.meta.processor.ClientRegisterWorker.handleClientRegister(ClientRegisterWorker.java:109)
at qunar.tc.qmq.meta.processor.ClientRegisterWorker.process(ClientRegisterWorker.java:80)
at qunar.tc.qmq.meta.processor.ClientRegisterWorker.process(ClientRegisterWorker.java:55)
at qunar.tc.qmq.concurrent.ActorSystem$Actor.processMessages(ActorSystem.java:173)
at qunar.tc.qmq.concurrent.ActorSystem$Actor.run(ActorSystem.java:155)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at qunar.tc.qmq.concurrent.NamedThreadFactory$1.run(NamedThreadFactory.java:52)
at java.lang.Thread.run(Thread.java:748)
from qmq.
[2021-08-09 15:47:57 INFO qunar.tc.qmq.meta.processor.BrokerRegisterProcessor] broker register request received. request: BrokerRegisterRequest{groupName='mytestbroker', brokerRole=0, brokerState=4, requestType=1, brokerAddress='10.37.129.2:20881'}
[2021-08-09 15:47:57 INFO qunar.tc.qmq.meta.processor.BrokerRegisterProcessor] Broker heartbeat response, request:BrokerRegisterRequest{groupName='mytestbroker', brokerRole=0, brokerState=4, requestType=1, brokerAddress='10.37.129.2:20881'}
broker 的日志也发一下,看这个日志像是 broker 没有转变成上线状态。
from qmq.
[2021-08-09 15:47:57 INFO qunar.tc.qmq.meta.processor.BrokerRegisterProcessor] broker register request received. request: BrokerRegisterRequest{groupName='mytestbroker', brokerRole=0, brokerState=4, requestType=1, brokerAddress='10.37.129.2:20881'} [2021-08-09 15:47:57 INFO qunar.tc.qmq.meta.processor.BrokerRegisterProcessor] Broker heartbeat response, request:BrokerRegisterRequest{groupName='mytestbroker', brokerRole=0, brokerState=4, requestType=1, brokerAddress='10.37.129.2:20881'}
broker 的日志也发一下,看这个日志像是 broker 没有转变成上线状态。
[2021-08-09 15:45:57 INFO qunar.tc.qmq.startup.ServerWrapper] qmq server init started
[2021-08-09 15:45:57 INFO qunar.tc.qmq.configuration.BrokerConfig] Broker meta updated. meta: BrokerAcquireMetaResponse{name='mytestbroker', role=MASTER, master=''}
Exception in thread "main" java.lang.RuntimeException: failed create directory /data/checkpoint
at qunar.tc.qmq.store.SnapshotStore.ensureStorePath(SnapshotStore.java:67)
at qunar.tc.qmq.store.SnapshotStore.(SnapshotStore.java:55)
at qunar.tc.qmq.store.CheckpointManager.(CheckpointManager.java:64)
at qunar.tc.qmq.store.DefaultStorage.(DefaultStorage.java:82)
at qunar.tc.qmq.startup.ServerWrapper.createStorage(ServerWrapper.java:130)
at qunar.tc.qmq.startup.ServerWrapper.start(ServerWrapper.java:89)
at qunar.tc.qmq.container.Bootstrap.main(Bootstrap.java:32)
就这一点点
from qmq.
看着是 broker 启动失败了,没有成功创建 checkpoint 目录。如果你没有 /data
目录,那需要修改下 broker 配置文件中的 store.root
,指定一个存在且有可写权限的目录。
from qmq.
看着是 broker 启动失败了,没有成功创建 checkpoint 目录。如果你没有
/data
目录,那需要修改下 broker 配置文件中的store.root
,指定一个存在且有可写权限的目录。
[2021-08-09 17:40:06 INFO qunar.tc.qmq.netty.NettyServer] listen on port 20882
[2021-08-09 17:40:06 INFO qunar.tc.qmq.netty.NettyServer] listen on port 20881
[2021-08-09 17:40:06 INFO qunar.tc.qmq.consumer.SubscriberStatusChecker] broker online status changed from false to true
[2021-08-09 17:40:06 INFO qunar.tc.qmq.startup.ServerWrapper] qmq server init done
可以了,谢谢!
from qmq.
看着是 broker 启动失败了,没有成功创建 checkpoint 目录。如果你没有
/data
目录,那需要修改下 broker 配置文件中的store.root
,指定一个存在且有可写权限的目录。
[2021-08-09 17:40:06 INFO qunar.tc.qmq.netty.NettyServer] listen on port 20882
[2021-08-09 17:40:06 INFO qunar.tc.qmq.netty.NettyServer] listen on port 20881
[2021-08-09 17:40:06 INFO qunar.tc.qmq.consumer.SubscriberStatusChecker] broker online status changed from false to true
[2021-08-09 17:40:06 INFO qunar.tc.qmq.startup.ServerWrapper] qmq server init done
可以了,谢谢!
from qmq.
Related Issues (20)
- 1.1.30 版本中非Spring环境手动pull时 空指针异常 HOT 1
- Cross-Site Scripting: Reflected
- There is a vulnerability in Apache Tomcat 7.0.30,upgrade recommended
- There is a vulnerability in Spring Framework 4.2.3.RELEASE,upgrade recommended
- There is a vulnerability in Apache Commons Collections 3.2.1 ,upgrade recommended
- There is a vulnerability in jackson-databind 2.9.9,upgrade recommended
- There is a vulnerability in Simple Logging Facade for Java (SLF4J) 1.7.25,upgrade recommended
- There is a vulnerability in Jetty: Java based HTTP/1.x, HTTP/2, Servlet, WebSocket Server 9.4.17.v20190418,upgrade recommended
- There is a vulnerability in MySQL Connector/J 5.1.39,upgrade recommended
- 咨询! HOT 1
- QMQ 跨地域复制方案 HOT 1
- 请教下consumer扩容的问题 HOT 2
- 贵司Q三剑客-QScheduler有没有开源计划 HOT 1
- QMQ版本计划 HOT 1
- init.sql 缺少字段,本地代码启动报错 HOT 2
- 有k8s部署方案吗
- centos系统日志框架堆栈溢出
- 同一个消费者组的多个实例 并发拉取消息时,是否存在重复消费的问题?
- [want] Go语言支持
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from qmq.