36 lines
1.1 KiB
Batchfile
36 lines
1.1 KiB
Batchfile
@echo off
|
|
setlocal enabledelayedexpansion
|
|
chcp 65001 >nul
|
|
title RocketMQ Consumer Group Initialization
|
|
|
|
:: BROKER_NAME
|
|
set "BROKER_NAME=broker-a"
|
|
:: 集群名称
|
|
set "CLUSTER_NAME=DefaultCluster"
|
|
|
|
echo.
|
|
echo [INFO] 正在创建消费者组
|
|
for %%g in (
|
|
"SIMULATION_FIFO_001"
|
|
"CID_standard_topic_sample"
|
|
"CID_ONSAPI_OWNER"
|
|
"SELF_TEST_C_GROUP"
|
|
"SIMULATION_FIFO_002"
|
|
"TOOLS_CONSUMER"
|
|
"CID_ONSAPI_PULL"
|
|
"CID_ONSAPI_PERMISSION"
|
|
"CID_RMQ_SYS_TRANS"
|
|
"FILTERSRV_CONSUMER"
|
|
"CID_ONS-HTTP-PROXY"
|
|
) do (
|
|
echo [INFO] 创建消费者组: %%~g
|
|
curl -X POST ^
|
|
http://localhost:8088/consumer/createOrUpdate.do ^
|
|
-H "Content-Type: application/json" ^
|
|
-d "{\"brokerNameList\":[\"%BROKER_NAME%\"],\"subscriptionGroupConfig\":{\"groupName\":\"%%~g\",\"consumeEnable\":true,\"consumeMessageOrderly\":false,\"consumeFromMinEnable\":true,\"consumeBroadcastEnable\":true,\"retryQueueNums\":1,\"retryMaxTimes\":16,\"brokerId\":0,\"whichBrokerWhenConsumeSlowly\":1},\"clusterNameList\":[\"%CLUSTER_NAME%\"]}"
|
|
echo.
|
|
)
|
|
|
|
echo 所有消费者组创建完成!
|
|
pause
|
|
exit /b 0 |