@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