CP-Ram opened a new issue #343: After deleting mqAdminExt subscriptionGroup,Again Automatically creating same Group URL: https://github.com/apache/rocketmq/issues/343 I'm using RocketMQ with c#. After deleteSubscriptionGroup from mqAdminExt, again automatically creating the group with the same name whatever I deleted. Here is the code: ``` public class Test { public DefaultMQProducer _producer; public DefaultMQAdminExt rocketMqAdmin; public DefaultMQPushConsumer _consumer; public WebSocket websocket; string tag = "4-0-00-00-000-0000-456"; string NameServeruri = "localhost:9876"; string consumerId = tag + "-Sessions-Consumer"; onServicStart() { var adminId = this.Context.NodeContext.NodeName + "-rocketmqAdmin"; rocketMqAdmin = new DefaultMQAdminExt(adminId); rocketMqAdmin.start(); var producerId = this.GetType().Name.ToString() + "-" + this.Context.NodeContext.NodeName + "-Producer"; _producer = new DefaultMQProducer(producerId); _producer.setNamesrvAddr(RocketMQBaseURL); _producer.start(); } consumer() { _consumer = new DefaultMQPushConsumer(consumerId); _consumer.setNamesrvAddr(NameServeruri); _consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET); _consumer.subscribe(topic, tag); MQMessageListener listener = new MQMessageListener(websocket, tag); _consumer.registerMessageListener(listener); _consumer.start(); } remove() { DefaultMQPushConsumer consumer = _consumer; consumer.shutdown(); var id = tag + "-Sessions-Consumer"; rocketMqAdmin.deleteSubscriptionGroup(RocketMQBrokerURL, id); } } ``` below are the broker logs: > 2018-06-20 13:38:11 INFO BrokerControllerScheduledThread1 - register broker to name server localhost:9876 OK > 2018-06-20 13:38:41 INFO BrokerControllerScheduledThread1 - register broker to name server localhost:9876 OK > 2018-06-20 13:38:58 INFO ClientManageThread_6 - auto create a subscription group, SubscriptionGroupConfig [groupName=4-46e7-911f-913ec76bdb17-Sessions-Consumer, consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true, retryQueueNums=1, retryMaxTimes=16, brokerId=0, whichBrokerWhenConsumeSlowly=1, notifyConsumerIdsChangedEnable=true] > 2018-06-20 13:38:58 INFO ClientManageThread_6 - create new topic TopicConfig [topicName=%RETRY%4-46e7-911f-913ec76bdb17-Sessions-Consumer, readQueueNums=1, writeQueueNums=1, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false] > 2018-06-20 13:38:58 INFO ClientManageThread_6 - register broker to name server localhost:9876 OK > 2018-06-20 13:38:58 INFO ClientManageThread_6 - new consumer connected, group: 4-46e7-911f-913ec76bdb17-Sessions-Consumer CONSUME_PASSIVELY CLUSTERING channel: ClientChannelInfo [channel=[id: 0x2aa59625, L:/192.168.1.30:10911 - R:/192.168.1.30:63488], clientId=169.254.184.73@30892, language=JAVA, version=252, lastUpdateTimestamp=1529473138639] > 2018-06-20 13:38:58 INFO ClientManageThread_6 - subscription changed, add new topic, group: 4-46e7-911f-913ec76bdb17-Sessions-Consumer SubscriptionData [classFilterMode=false, topic=%RETRY%4-46e7-911f-913ec76bdb17-Sessions-Consumer, subString=*, tagsSet=[], codeSet=[], subVersion=1529473138565, expressionType=null] > 2018-06-20 13:38:58 INFO ClientManageThread_6 - subscription changed, add new topic, group: 4-46e7-911f-913ec76bdb17-Sessions-Consumer SubscriptionData [classFilterMode=false, topic=251122b1-fec6-491d-969a-44a87138fc21, subString=4-46e7-911f-913ec76bdb17, tagsSet=[4-46e7-911f-913ec76bdb17], codeSet=[-487735314], subVersion=1529473138531, expressionType=null] > 2018-06-20 13:38:58 INFO ClientManageThread_6 - registerConsumer info changed ConsumerData [groupName=4-46e7-911f-913ec76bdb17-Sessions-Consumer, consumeType=CONSUME_PASSIVELY, messageModel=CLUSTERING, consumeFromWhere=CONSUME_FROM_LAST_OFFSET, unitMode=false, subscriptionDataSet=[SubscriptionData [classFilterMode=false, topic=%RETRY%4-46e7-911f-913ec76bdb17-Sessions-Consumer, subString=*, tagsSet=[], codeSet=[], subVersion=1529473138565, expressionType=null], SubscriptionData [classFilterMode=false, topic=251122b1-fec6-491d-969a-44a87138fc21, subString=4-46e7-911f-913ec76bdb17, tagsSet=[4-46e7-911f-913ec76bdb17], codeSet=[-487735314], subVersion=1529473138531, expressionType=null]]] 192.168.1.30:63488 > 2018-06-20 13:38:58 INFO ClientManageThread_7 - subscription changed, group: 4-46e7-911f-913ec76bdb17-Sessions-Consumer OLD: SubscriptionData [classFilterMode=false, topic=%RETRY%4-46e7-911f-913ec76bdb17-Sessions-Consumer, subString=*, tagsSet=[], codeSet=[], subVersion=1529473138565, expressionType=null] NEW: SubscriptionData [classFilterMode=false, topic=%RETRY%4-46e7-911f-913ec76bdb17-Sessions-Consumer, subString=*, tagsSet=[], codeSet=[], subVersion=1529473138787, expressionType=null] > 2018-06-20 13:39:10 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes > 2018-06-20 13:39:10 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes > 2018-06-20 13:39:11 INFO BrokerControllerScheduledThread1 - register broker to name server localhost:9876 OK > 2018-06-20 13:39:41 INFO BrokerControllerScheduledThread1 - register broker to name server localhost:9876 OK > 2018-06-20 13:40:07 INFO ClientManageThread_22 - unregister a consumer[4-46e7-911f-913ec76bdb17-Sessions-Consumer] from consumerGroupInfo ClientChannelInfo [channel=[id: 0x2aa59625, L:/192.168.1.30:10911 - R:/192.168.1.30:63488], clientId=169.254.184.73@30892, language=JAVA, version=252, lastUpdateTimestamp=1529473204921] > 2018-06-20 13:40:07 INFO ClientManageThread_22 - unregister consumer ok, no any connection, and remove consumer group, 4-46e7-911f-913ec76bdb17-Sessions-Consumer > 2018-06-20 13:40:07 INFO AdminBrokerThread_8 - deleteSubscriptionGroup called by 127.0.0.1:50735 > **2018-06-20 13:40:07 INFO AdminBrokerThread_8 - delete subscription group OK, subscription** group:SubscriptionGroupConfig [groupName=4-46e7-911f-913ec76bdb17-Sessions-Consumer, consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true, retryQueueNums=1, retryMaxTimes=16, brokerId=0, whichBrokerWhenConsumeSlowly=1, notifyConsumerIdsChangedEnable=true] > 2018-06-20 13:40:10 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes > 2018-06-20 13:40:10 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 0 bytes > 2018-06-20 13:40:11 INFO BrokerControllerScheduledThread1 - register broker to name server localhost:9876 OK > ### 2018-06-20 13:40:21 INFO PullMessageThread_8 - auto create a subscription group, SubscriptionGroupConfig [groupName=4-46e7-911f-913ec76bdb17-Sessions-Consumer, consumeEnable=true, consumeFromMinEnable=true, consumeBroadcastEnable=true, retryQueueNums=1, retryMaxTimes=16, brokerId=0, whichBrokerWhenConsumeSlowly=1, notifyConsumerIdsChangedEnable=true] > 2018-06-20 13:40:21 WARN PullMessageThread_8 - The consumer's group info not exist, group: 4-46e7-911f-913ec76bdb17-Sessions-Consumer But while deleting from RocketMQ console it working properly and also unregister producer group from channelTableInfo and not calling PullMessageThread auto create.But in case of c# above code AdminExt with PullMessage Thread auto create also calling. Any help.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
