[GitHub] [incubator-inlong] dockerzhang opened a new issue #1342: [INLONG-753] Create tube consumer group failed where the group exists

Wed, 28 Jul 2021 04:44:40 -0700 


dockerzhang opened a new issue #1342:
URL: https://github.com/apache/incubator-inlong/issues/1342


   <p>When the tube consumer group exists (associated to business id), there 
are error in `TubeMqOptService#createNewConsumerGroup`.</p>
   
   <p>For example：</p>
   <ol>
        <li>my business is `b_heal_test`, without data storage, when it passed 
approval, the tube topic and consumer group will all created.</li>
        <li>i add a new hive storage, then passed approval, there are error 
info in log file:</li>
   </ol>
   
   
   <p>```shell</p>
   
   <p>2021-07-19 12:33:30.536 <span 
class="error">&#91;async-task-event-notifier-0&#93;</span> ERROR 
o.a.i.m.service.thirdpart.mq.TubeMqOptService:95 - fail to create tube consumer 
group {"clusterId":1,"createUser":"admin","groupNameJsonSet":[</p>
   {"topicName":"docker_test_8","groupName":"sort_docker_test_8_consumer_group"}
   <p>]}<br/>
   org.apache.inlong.manager.common.exceptions.BusinessException: Duplicate add 
allowed consumerGroupName info, exist record is: 
org.apache.inlong.tubemq.server.master.bdbstore.bdbentitys.BdbConsumerGroupEntity@1d036793<span
 
class="error">&#91;recordKey=docker_test_8:sort_docker_test_8_consumer_group,topicName=docker_test_8,consumerGroupName=sort_docker_test_8_consumer_group,createUser=tubeAdmin,createDate=Sat
 Jul 10 15:44:18 CST 2021,attributes=<null>&#93;</span><br/>
    at 
org.apache.inlong.manager.service.thirdpart.mq.TubeMqOptService.createNewConsumerGroup(TubeMqOptService.java:92)<br/>
    at 
org.apache.inlong.manager.service.thirdpart.mq.CreateTubeConsumeGroupTaskEventListener.listen(CreateTubeConsumeGroupTaskEventListener.java:109)<br/>
    at 
org.apache.inlong.manager.workflow.core.event.LogableEventListener.executeListenerWithLog(LogableEventListener.java:80)<br/>
    at 
org.apache.inlong.manager.workflow.core.event.LogableEventListener.listen(LogableEventListener.java:58)<br/>
    at 
org.apache.inlong.manager.workflow.core.event.task.TaskEventNotifier.lambda$null$1(TaskEventNotifier.java:97)<br/>
    at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)<br/>
    at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)<br/>
    at java.lang.Thread.run(Thread.java:748)<br/>
   2021-07-19 12:33:30.537 <span 
class="error">&#91;async-task-event-notifier-0&#93;</span> ERROR 
o.a.i.m.s.t.m.CreateTubeConsumeGroupTaskEventListener:111 - create tube consume 
group for bid=b_docker_test_8 error Duplicate add allowed consumerGroupName 
info, exist record is: 
org.apache.inlong.tubemq.server.master.bdbstore.bdbentitys.BdbConsumerGroupEntity@1d036793<span
 
class="error">&#91;recordKey=docker_test_8:sort_docker_test_8_consumer_group,topicName=docker_test_8,consumerGroupName=sort_docker_test_8_consumer_group,createUser=tubeAdmin,createDate=Sat
 Jul 10 15:44:18 CST 2021,attributes=<null>&#93;</span><br/>
   org.apache.inlong.manager.common.exceptions.BusinessException: Duplicate add 
allowed consumerGroupName info, exist record is: 
org.apache.inlong.tubemq.server.master.bdbstore.bdbentitys.BdbConsumerGroupEntity@1d036793<span
 
class="error">&#91;recordKey=docker_test_8:sort_docker_test_8_consumer_group,topicName=docker_test_8,consumerGroupName=sort_docker_test_8_consumer_group,createUser=tubeAdmin,createDate=Sat
 Jul 10 15:44:18 CST 2021,attributes=<null>&#93;</span><br/>
    at 
org.apache.inlong.manager.service.thirdpart.mq.TubeMqOptService.createNewConsumerGroup(TubeMqOptService.java:92)<br/>
    at 
org.apache.inlong.manager.service.thirdpart.mq.CreateTubeConsumeGroupTaskEventListener.listen(CreateTubeConsumeGroupTaskEventListener.java:109)<br/>
    at 
org.apache.inlong.manager.workflow.core.event.LogableEventListener.executeListenerWithLog(LogableEventListener.java:80)<br/>
    at 
org.apache.inlong.manager.workflow.core.event.LogableEventListener.listen(LogableEventListener.java:58)<br/>
    at 
org.apache.inlong.manager.workflow.core.event.task.TaskEventNotifier.lambda$null$1(TaskEventNotifier.java:97)<br/>
    at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)<br/>
    at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)<br/>
    at java.lang.Thread.run(Thread.java:748)</p>
   
   <p>```</p>
   
   <p> </p>
   
   <p>*<b>The problem is: before creating a consumer group, it did not check 
whether the consumer group exists.</b>*</p>
   <i>JIRA link - <a 
href="https://issues.apache.org/jira/browse/INLONG-753";>[INLONG-753]</a> 
created by healchow</i>


-- 
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]

Reply via email to