[
https://issues.apache.org/jira/browse/INLONG-753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated INLONG-753:
----------------------------------
Labels: pull-request-available (was: )
> Create tube consumer group failed where the group exists
> --------------------------------------------------------
>
> Key: INLONG-753
> URL: https://issues.apache.org/jira/browse/INLONG-753
> Project: Apache InLong
> Issue Type: New Feature
> Components: inlong-manager
> Reporter: healchow
> Assignee: healchow
> Priority: Major
> Labels: pull-request-available
> Fix For: 0.10.0
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> When the tube consumer group exists (associated to business id), there are
> error in `TubeMqOptService#createNewConsumerGroup`.
> For example：
> # my business is `b_heal_test`, without data storage, when it passed
> approval, the tube topic and consumer group will all created.
> # i add a new hive storage, then passed approval, there are error info in
> log file:
> ```shell
> 2021-07-19 12:33:30.536 [async-task-event-notifier-0] ERROR
> o.a.i.m.service.thirdpart.mq.TubeMqOptService:95 - fail to create tube
> consumer group
> \{"clusterId":1,"createUser":"admin","groupNameJsonSet":[{"topicName":"docker_test_8","groupName":"sort_docker_test_8_consumer_group"}]}
> 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[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>]
> at
> org.apache.inlong.manager.service.thirdpart.mq.TubeMqOptService.createNewConsumerGroup(TubeMqOptService.java:92)
> at
> org.apache.inlong.manager.service.thirdpart.mq.CreateTubeConsumeGroupTaskEventListener.listen(CreateTubeConsumeGroupTaskEventListener.java:109)
> at
> org.apache.inlong.manager.workflow.core.event.LogableEventListener.executeListenerWithLog(LogableEventListener.java:80)
> at
> org.apache.inlong.manager.workflow.core.event.LogableEventListener.listen(LogableEventListener.java:58)
> at
> org.apache.inlong.manager.workflow.core.event.task.TaskEventNotifier.lambda$null$1(TaskEventNotifier.java:97)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> 2021-07-19 12:33:30.537 [async-task-event-notifier-0] 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[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>]
> 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[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>]
> at
> org.apache.inlong.manager.service.thirdpart.mq.TubeMqOptService.createNewConsumerGroup(TubeMqOptService.java:92)
> at
> org.apache.inlong.manager.service.thirdpart.mq.CreateTubeConsumeGroupTaskEventListener.listen(CreateTubeConsumeGroupTaskEventListener.java:109)
> at
> org.apache.inlong.manager.workflow.core.event.LogableEventListener.executeListenerWithLog(LogableEventListener.java:80)
> at
> org.apache.inlong.manager.workflow.core.event.LogableEventListener.listen(LogableEventListener.java:58)
> at
> org.apache.inlong.manager.workflow.core.event.task.TaskEventNotifier.lambda$null$1(TaskEventNotifier.java:97)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> ```
>
> **The problem is: before creating a consumer group, it did not check whether
> the consumer group exists.**
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
