Replies: 2 comments
-
this.brokerController.getBrokerOuterAPI().getAllTopicConfig(masterAddrBak) 接口返回的数据 message.type 哪里没有处理对? |
Beta Was this translation helpful? Give feedback.
0 replies
-
![]() |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
2025-05-07 17:34:57 INFO BrokerControllerScheduledThread1 - create new topic [TopicConfig [topicName=%RETRY%test-group, readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false, attributes={}]]
2025-05-07 17:34:57 ERROR BrokerControllerScheduledThread1 - SyncTopicConfig Exception, 10.200.135.227:10911
java.lang.RuntimeException: only add attribute is supported while creating topic. key: essage.type
at org.apache.rocketmq.common.attribute.AttributeUtil.alterCurrentAttributes(AttributeUtil.java:53)
at org.apache.rocketmq.broker.topic.TopicConfigManager.updateSingleTopicConfigWithoutPersist(TopicConfigManager.java:506)
at java.util.concurrent.ConcurrentHashMap$ValuesView.forEach(ConcurrentHashMap.java:4705)
at org.apache.rocketmq.broker.slave.SlaveSynchronize.syncTopicConfig(SlaveSynchronize.java:102)
默认创建的 重试队列 无法同步,什么原因。
Beta Was this translation helpful? Give feedback.
All reactions