humkum commented on issue #9984:
URL: https://github.com/apache/rocketmq/issues/9984#issuecomment-3721706058
There appears to be a bug: because the deletion logic is outside the if
statement, it's causing all topic and subscription group configurations to be
deleted every time the slave node synchronizes metadata. I've submitted a PR to
fix this bug; could you please review it?
> ```
> 2026-01-08 10:09:13 INFO BrokerControllerScheduledThread1 - Update slave
Subscription Group from master, 172.25.221.11:30911
> 2026-01-08 10:09:13 INFO BrokerControllerScheduledThread1 - Update slave
Message Request Mode from master, 172.25.221.11:30911
> 2026-01-08 10:09:22 INFO ReplicasManager_ScheduledService_2 - Update
controller leader address to 172.25.221.11:9878
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 -
getAllTopicConfig from seq 0, max 2000, dataVersion
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - get all topic
config, totalTopicNum: 53
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%wt_hkg_risk_judge_queue_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=UNCHECK_REFUND_TOPIC, readQueueNums=8,
writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=%RETRY%wt-clearing_success_business_queue_group, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_aus_risk_judge_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=%RETRY%wt-clearing_success_activity_queue_group, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=%RETRY%wt_jpn_risk_2_clear_queue_group, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%UNCHECK_REFUND_GROUP,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=SCHEDULE_TOPIC_XXXX, readQueueNums=18,
writeQueueNums=18, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%wt-payee_add_suc_queue_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%wt_alarm_exception_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=rmq_sys_REVIVE_LOG_eu,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt-payee_add_suc_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=SELF_TEST_TOPIC, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_jpn_risk_2_clear_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_eur_risk_judge_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%wt_aus_risk_judge_queue_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=rmq_sys_wheel_timer, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=%RETRY%wt_aus_risk_2_clear_queue_group, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=wt-clearing_success_business_queue_topic, readQueueNums=8,
writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%tp-clearing_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_jpn_risk_judge_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=wt-clearing_success_compliance_queue_topic, readQueueNums=8,
writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%wt_risk_judge_queue_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=%RETRY%wt-order_refund_suc_queue_group, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt-kyc_pass_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%TOOLS_CONSUMER,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=wt-clearing_success_activity_queue_topic, readQueueNums=8,
writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%wt_eur_risk_judge_queue_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=RMQ_SYS_TRANS_HALF_TOPIC,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt-order_refund_suc_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=eu, readQueueNums=16,
writeQueueNums=16, perm=RWX, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_eur_risk_2_clear_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_risk_2_clear_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt-clearing_delay_sync_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=DELAY}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=rmq_sys_SYNC_BROKER_MEMBER_broker-a,
readQueueNums=1, writeQueueNums=1, perm=--X, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=broker-a, readQueueNums=1,
writeQueueNums=1, perm=RWX, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=%RETRY%wt_hkg_risk_2_clear_queue_group, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%wt_risk_2_clear_queue_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=RMQ_SYS_TRANS_OP_HALF_TOPIC,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%wt_jpn_risk_judge_queue_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=%RETRY%wt-clearing_success_compliance_queue_group, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_hkg_risk_judge_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig
[topicName=%RETRY%wt_eur_risk_2_clear_queue_group, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%wt-kyc_pass_queue_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_aus_risk_2_clear_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_alarm_exception_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=%RETRY%wt-clearing_delay_sync_group,
readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_risk_judge_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=BenchmarkTest, readQueueNums=1024,
writeQueueNums=1024, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=tp-clearing_topic, readQueueNums=8,
writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=wt_hkg_risk_2_clear_queue_topic,
readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG,
topicSysFlag=0, order=false, attributes={message.type=NORMAL}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=OFFSET_MOVED_EVENT, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete topic
config OK, topic: TopicConfig [topicName=eu_REPLY_TOPIC, readQueueNums=1,
writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0,
order=false, attributes={}]
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - Update slave
topic config from master, 172.25.221.11:30911
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - Update slave
consumer offset from master, 172.25.221.11:30911
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - load
/data/rocketmq/store/config/delayOffset.json OK
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - Update slave
delay offset from master, 172.25.221.11:30911
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 -
getAllSubscriptionGroup from seq 0, max 2000, dataVersion
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - get all
subscription group config, totalGroupNum: 29
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt_hkg_risk_judge_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=SELF_TEST_C_GROUP, consumeEnable=true,
consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt_hkg_risk_2_clear_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=CID_ONSAPI_OWNER, consumeEnable=true,
consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt_alarm_exception_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=UNCHECK_REFUND_GROUP,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt_risk_2_clear_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=topup_Group, consumeEnable=true,
consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt-clearing_delay_sync_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt-clearing_success_compliance_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt_aus_risk_judge_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt-payee_add_suc_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt-kyc_pass_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=CID_ONSAPI_PERMISSION,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt_eur_risk_2_clear_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt_risk_judge_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt_jpn_risk_2_clear_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=CID_RMQ_SYS_TRANS, consumeEnable=true,
consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=TOOLS_CONSUMER, consumeEnable=true,
consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt_jpn_risk_judge_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=wt-clearing_success_business_queue_group,
consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> 2026-01-08 10:09:25 INFO BrokerControllerScheduledThread1 - delete
subscription group OK, subscription
group:SubscriptionGroupConfig{groupName=CID_ONS-HTTP-PROXY, consumeEnable=true,
consumeFromMinEnable=true, consumeBroadcastEnable=true,
consumeMessageOrderly=false, retryQueueNums=1, retryMaxTimes=16,
groupRetryPolicy=GroupRetryPolicy{type=CUSTOMIZED, exponentialRetryPolicy=null,
customizedRetryPolicy=null}, brokerId=0, whichBrokerWhenConsumeSlowly=1,
notifyConsumerIdsChangedEnable=true, groupSysFlag=0, consumeTimeoutMinute=15,
subscriptionDataSet=null, attributes={}}
> ```
>
> [@humkum](https://github.com/humkum) Appreciate your reply
There appears to be a bug: because the deletion logic is outside the if
statement, it's causing all topic and subscription group configurations to be
deleted every time the slave node synchronizes metadata. I've submitted a PR to
fix this bug; could you please review it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
