diff --git a/base/Resources/rocketmq/sbin/store/abort b/base/Resources/rocketmq/sbin/store/abort new file mode 100644 index 0000000..d25ee82 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/abort @@ -0,0 +1 @@ +7792 \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/abort.bak b/base/Resources/rocketmq/sbin/store/abort.bak new file mode 100644 index 0000000..e69de29 diff --git a/base/Resources/rocketmq/sbin/store/checkpoint b/base/Resources/rocketmq/sbin/store/checkpoint new file mode 100644 index 0000000..08e7df1 Binary files /dev/null and b/base/Resources/rocketmq/sbin/store/checkpoint differ diff --git a/base/Resources/rocketmq/sbin/store/config/consumerFilter.json b/base/Resources/rocketmq/sbin/store/config/consumerFilter.json new file mode 100644 index 0000000..79d47d1 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/consumerFilter.json @@ -0,0 +1,3 @@ +{ + "filterDataByTopic":{} +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/consumerFilter.json.bak b/base/Resources/rocketmq/sbin/store/config/consumerFilter.json.bak new file mode 100644 index 0000000..79d47d1 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/consumerFilter.json.bak @@ -0,0 +1,3 @@ +{ + "filterDataByTopic":{} +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/consumerOffset.json b/base/Resources/rocketmq/sbin/store/config/consumerOffset.json new file mode 100644 index 0000000..d402fd5 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/consumerOffset.json @@ -0,0 +1,12 @@ +{ + "dataVersion":{ + "counter":0, + "stateVersion":0, + "timestamp":1755222420222 + }, + "groupTopicMap":{}, + "offsetTable":{ + "DefaultHeartBeatSyncerTopic@CID_DefaultHeartBeatSyncerTopic@broadcast":{0:0 + } + } +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/consumerOffset.json.bak b/base/Resources/rocketmq/sbin/store/config/consumerOffset.json.bak new file mode 100644 index 0000000..d150e1d --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/consumerOffset.json.bak @@ -0,0 +1,9 @@ +{ + "dataVersion":{ + "counter":0, + "stateVersion":0, + "timestamp":1755222420222 + }, + "groupTopicMap":{}, + "offsetTable":{} +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/consumerOrderInfo.json b/base/Resources/rocketmq/sbin/store/config/consumerOrderInfo.json new file mode 100644 index 0000000..12031de --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/consumerOrderInfo.json @@ -0,0 +1,3 @@ +{ + "table":{} +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/consumerOrderInfo.json.bak b/base/Resources/rocketmq/sbin/store/config/consumerOrderInfo.json.bak new file mode 100644 index 0000000..12031de --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/consumerOrderInfo.json.bak @@ -0,0 +1,3 @@ +{ + "table":{} +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/delayOffset.json b/base/Resources/rocketmq/sbin/store/config/delayOffset.json new file mode 100644 index 0000000..42efe2c --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/delayOffset.json @@ -0,0 +1,8 @@ +{ + "dataVersion":{ + "counter":0, + "stateVersion":0, + "timestamp":1755222420285 + }, + "offsetTable":{} +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/delayOffset.json.bak b/base/Resources/rocketmq/sbin/store/config/delayOffset.json.bak new file mode 100644 index 0000000..42efe2c --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/delayOffset.json.bak @@ -0,0 +1,8 @@ +{ + "dataVersion":{ + "counter":0, + "stateVersion":0, + "timestamp":1755222420285 + }, + "offsetTable":{} +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/subscriptionGroup.json b/base/Resources/rocketmq/sbin/store/config/subscriptionGroup.json new file mode 100644 index 0000000..0f48b85 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/subscriptionGroup.json @@ -0,0 +1,172 @@ +{ + "dataVersion":{ + "counter":1, + "stateVersion":0, + "timestamp":1755222433118 + }, + "forbiddenTable":{}, + "subscriptionGroupTable":{ + "SELF_TEST_C_GROUP":{ + "attributes":{}, + "brokerId":0, + "consumeBroadcastEnable":true, + "consumeEnable":true, + "consumeFromMinEnable":true, + "consumeMessageOrderly":false, + "consumeTimeoutMinute":15, + "groupName":"SELF_TEST_C_GROUP", + "groupRetryPolicy":{ + "type":"CUSTOMIZED" + }, + "groupSysFlag":0, + "notifyConsumerIdsChangedEnable":true, + "retryMaxTimes":16, + "retryQueueNums":1, + "whichBrokerWhenConsumeSlowly":1 + }, + "CID_ONSAPI_OWNER":{ + "attributes":{}, + "brokerId":0, + "consumeBroadcastEnable":true, + "consumeEnable":true, + "consumeFromMinEnable":true, + "consumeMessageOrderly":false, + "consumeTimeoutMinute":15, + "groupName":"CID_ONSAPI_OWNER", + "groupRetryPolicy":{ + "type":"CUSTOMIZED" + }, + "groupSysFlag":0, + "notifyConsumerIdsChangedEnable":true, + "retryMaxTimes":16, + "retryQueueNums":1, + "whichBrokerWhenConsumeSlowly":1 + }, + "CID_ONSAPI_PERMISSION":{ + "attributes":{}, + "brokerId":0, + "consumeBroadcastEnable":true, + "consumeEnable":true, + "consumeFromMinEnable":true, + "consumeMessageOrderly":false, + "consumeTimeoutMinute":15, + "groupName":"CID_ONSAPI_PERMISSION", + "groupRetryPolicy":{ + "type":"CUSTOMIZED" + }, + "groupSysFlag":0, + "notifyConsumerIdsChangedEnable":true, + "retryMaxTimes":16, + "retryQueueNums":1, + "whichBrokerWhenConsumeSlowly":1 + }, + "CID_RMQ_SYS_TRANS":{ + "attributes":{}, + "brokerId":0, + "consumeBroadcastEnable":true, + "consumeEnable":true, + "consumeFromMinEnable":true, + "consumeMessageOrderly":false, + "consumeTimeoutMinute":15, + "groupName":"CID_RMQ_SYS_TRANS", + "groupRetryPolicy":{ + "type":"CUSTOMIZED" + }, + "groupSysFlag":0, + "notifyConsumerIdsChangedEnable":true, + "retryMaxTimes":16, + "retryQueueNums":1, + "whichBrokerWhenConsumeSlowly":1 + }, + "TOOLS_CONSUMER":{ + "attributes":{}, + "brokerId":0, + "consumeBroadcastEnable":true, + "consumeEnable":true, + "consumeFromMinEnable":true, + "consumeMessageOrderly":false, + "consumeTimeoutMinute":15, + "groupName":"TOOLS_CONSUMER", + "groupRetryPolicy":{ + "type":"CUSTOMIZED" + }, + "groupSysFlag":0, + "notifyConsumerIdsChangedEnable":true, + "retryMaxTimes":16, + "retryQueueNums":1, + "whichBrokerWhenConsumeSlowly":1 + }, + "CID_ONS-HTTP-PROXY":{ + "attributes":{}, + "brokerId":0, + "consumeBroadcastEnable":true, + "consumeEnable":true, + "consumeFromMinEnable":true, + "consumeMessageOrderly":false, + "consumeTimeoutMinute":15, + "groupName":"CID_ONS-HTTP-PROXY", + "groupRetryPolicy":{ + "type":"CUSTOMIZED" + }, + "groupSysFlag":0, + "notifyConsumerIdsChangedEnable":true, + "retryMaxTimes":16, + "retryQueueNums":1, + "whichBrokerWhenConsumeSlowly":1 + }, + "FILTERSRV_CONSUMER":{ + "attributes":{}, + "brokerId":0, + "consumeBroadcastEnable":true, + "consumeEnable":true, + "consumeFromMinEnable":true, + "consumeMessageOrderly":false, + "consumeTimeoutMinute":15, + "groupName":"FILTERSRV_CONSUMER", + "groupRetryPolicy":{ + "type":"CUSTOMIZED" + }, + "groupSysFlag":0, + "notifyConsumerIdsChangedEnable":true, + "retryMaxTimes":16, + "retryQueueNums":1, + "whichBrokerWhenConsumeSlowly":1 + }, + "CID_ONSAPI_PULL":{ + "attributes":{}, + "brokerId":0, + "consumeBroadcastEnable":true, + "consumeEnable":true, + "consumeFromMinEnable":true, + "consumeMessageOrderly":false, + "consumeTimeoutMinute":15, + "groupName":"CID_ONSAPI_PULL", + "groupRetryPolicy":{ + "type":"CUSTOMIZED" + }, + "groupSysFlag":0, + "notifyConsumerIdsChangedEnable":true, + "retryMaxTimes":16, + "retryQueueNums":1, + "whichBrokerWhenConsumeSlowly":1 + }, + "CID_DefaultHeartBeatSyncerTopic":{ + "attributes":{}, + "brokerId":0, + "consumeBroadcastEnable":true, + "consumeEnable":true, + "consumeFromMinEnable":true, + "consumeMessageOrderly":false, + "consumeTimeoutMinute":15, + "groupName":"CID_DefaultHeartBeatSyncerTopic", + "groupRetryPolicy":{ + "type":"CUSTOMIZED" + }, + "groupSysFlag":0, + "notifyConsumerIdsChangedEnable":true, + "retryMaxTimes":16, + "retryQueueNums":1, + "whichBrokerWhenConsumeSlowly":1 + } + } +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/timercheck b/base/Resources/rocketmq/sbin/store/config/timercheck new file mode 100644 index 0000000..bc44ce1 Binary files /dev/null and b/base/Resources/rocketmq/sbin/store/config/timercheck differ diff --git a/base/Resources/rocketmq/sbin/store/config/timermetrics b/base/Resources/rocketmq/sbin/store/config/timermetrics new file mode 100644 index 0000000..45795e4 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/timermetrics @@ -0,0 +1 @@ +{"dataVersion":{"counter":0,"stateVersion":0,"timestamp":1755222420494},"timingCount":{}} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/timermetrics.bak b/base/Resources/rocketmq/sbin/store/config/timermetrics.bak new file mode 100644 index 0000000..45795e4 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/timermetrics.bak @@ -0,0 +1 @@ +{"dataVersion":{"counter":0,"stateVersion":0,"timestamp":1755222420494},"timingCount":{}} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/topics.json b/base/Resources/rocketmq/sbin/store/config/topics.json new file mode 100644 index 0000000..ccff235 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/topics.json @@ -0,0 +1,159 @@ +{ + "dataVersion":{ + "counter":2, + "stateVersion":0, + "timestamp":1755222433132 + }, + "topicConfigTable":{ + "SCHEDULE_TOPIC_XXXX":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":18, + "topicFilterType":"SINGLE_TAG", + "topicName":"SCHEDULE_TOPIC_XXXX", + "topicSysFlag":0, + "writeQueueNums":18 + }, + "SELF_TEST_TOPIC":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"SELF_TEST_TOPIC", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "rmq_sys_wheel_timer":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"rmq_sys_wheel_timer", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "%RETRY%CID_DefaultHeartBeatSyncerTopic":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"%RETRY%CID_DefaultHeartBeatSyncerTopic", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "DefaultCluster":{ + "attributes":{}, + "order":false, + "perm":7, + "readQueueNums":16, + "topicFilterType":"SINGLE_TAG", + "topicName":"DefaultCluster", + "topicSysFlag":0, + "writeQueueNums":16 + }, + "DefaultCluster_REPLY_TOPIC":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"DefaultCluster_REPLY_TOPIC", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "rmq_sys_REVIVE_LOG_DefaultCluster":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":8, + "topicFilterType":"SINGLE_TAG", + "topicName":"rmq_sys_REVIVE_LOG_DefaultCluster", + "topicSysFlag":0, + "writeQueueNums":8 + }, + "RMQ_SYS_TRANS_HALF_TOPIC":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"RMQ_SYS_TRANS_HALF_TOPIC", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "rmq_sys_SYNC_BROKER_MEMBER_broker-a":{ + "attributes":{}, + "order":false, + "perm":1, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"rmq_sys_SYNC_BROKER_MEMBER_broker-a", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "broker-a":{ + "attributes":{}, + "order":false, + "perm":7, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"broker-a", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "RMQ_SYS_TRANS_OP_HALF_TOPIC":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"RMQ_SYS_TRANS_OP_HALF_TOPIC", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "TBW102":{ + "attributes":{}, + "order":false, + "perm":7, + "readQueueNums":8, + "topicFilterType":"SINGLE_TAG", + "topicName":"TBW102", + "topicSysFlag":0, + "writeQueueNums":8 + }, + "BenchmarkTest":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1024, + "topicFilterType":"SINGLE_TAG", + "topicName":"BenchmarkTest", + "topicSysFlag":0, + "writeQueueNums":1024 + }, + "DefaultHeartBeatSyncerTopic":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"DefaultHeartBeatSyncerTopic", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "OFFSET_MOVED_EVENT":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"OFFSET_MOVED_EVENT", + "topicSysFlag":0, + "writeQueueNums":1 + } + } +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/topics.json.bak b/base/Resources/rocketmq/sbin/store/config/topics.json.bak new file mode 100644 index 0000000..1c28a18 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/topics.json.bak @@ -0,0 +1,149 @@ +{ + "dataVersion":{ + "counter":1, + "stateVersion":0, + "timestamp":1755222432918 + }, + "topicConfigTable":{ + "SCHEDULE_TOPIC_XXXX":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":18, + "topicFilterType":"SINGLE_TAG", + "topicName":"SCHEDULE_TOPIC_XXXX", + "topicSysFlag":0, + "writeQueueNums":18 + }, + "SELF_TEST_TOPIC":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"SELF_TEST_TOPIC", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "rmq_sys_wheel_timer":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"rmq_sys_wheel_timer", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "DefaultCluster":{ + "attributes":{}, + "order":false, + "perm":7, + "readQueueNums":16, + "topicFilterType":"SINGLE_TAG", + "topicName":"DefaultCluster", + "topicSysFlag":0, + "writeQueueNums":16 + }, + "DefaultCluster_REPLY_TOPIC":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"DefaultCluster_REPLY_TOPIC", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "rmq_sys_REVIVE_LOG_DefaultCluster":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":8, + "topicFilterType":"SINGLE_TAG", + "topicName":"rmq_sys_REVIVE_LOG_DefaultCluster", + "topicSysFlag":0, + "writeQueueNums":8 + }, + "RMQ_SYS_TRANS_HALF_TOPIC":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"RMQ_SYS_TRANS_HALF_TOPIC", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "rmq_sys_SYNC_BROKER_MEMBER_broker-a":{ + "attributes":{}, + "order":false, + "perm":1, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"rmq_sys_SYNC_BROKER_MEMBER_broker-a", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "broker-a":{ + "attributes":{}, + "order":false, + "perm":7, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"broker-a", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "RMQ_SYS_TRANS_OP_HALF_TOPIC":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"RMQ_SYS_TRANS_OP_HALF_TOPIC", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "TBW102":{ + "attributes":{}, + "order":false, + "perm":7, + "readQueueNums":8, + "topicFilterType":"SINGLE_TAG", + "topicName":"TBW102", + "topicSysFlag":0, + "writeQueueNums":8 + }, + "BenchmarkTest":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1024, + "topicFilterType":"SINGLE_TAG", + "topicName":"BenchmarkTest", + "topicSysFlag":0, + "writeQueueNums":1024 + }, + "DefaultHeartBeatSyncerTopic":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"DefaultHeartBeatSyncerTopic", + "topicSysFlag":0, + "writeQueueNums":1 + }, + "OFFSET_MOVED_EVENT":{ + "attributes":{}, + "order":false, + "perm":6, + "readQueueNums":1, + "topicFilterType":"SINGLE_TAG", + "topicName":"OFFSET_MOVED_EVENT", + "topicSysFlag":0, + "writeQueueNums":1 + } + } +} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/transactionMetrics b/base/Resources/rocketmq/sbin/store/config/transactionMetrics new file mode 100644 index 0000000..b87fbf7 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/transactionMetrics @@ -0,0 +1 @@ +{"dataVersion":{"counter":0,"stateVersion":0,"timestamp":1755222421968},"transactionCount":{}} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/config/transactionMetrics.bak b/base/Resources/rocketmq/sbin/store/config/transactionMetrics.bak new file mode 100644 index 0000000..b87fbf7 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/config/transactionMetrics.bak @@ -0,0 +1 @@ +{"dataVersion":{"counter":0,"stateVersion":0,"timestamp":1755222421968},"transactionCount":{}} \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/lock b/base/Resources/rocketmq/sbin/store/lock new file mode 100644 index 0000000..19104f1 --- /dev/null +++ b/base/Resources/rocketmq/sbin/store/lock @@ -0,0 +1 @@ +lock \ No newline at end of file diff --git a/base/Resources/rocketmq/sbin/store/timerwheel b/base/Resources/rocketmq/sbin/store/timerwheel new file mode 100644 index 0000000..7a1b61e Binary files /dev/null and b/base/Resources/rocketmq/sbin/store/timerwheel differ