healchow created INLONG-753:
-------------------------------
Summary: 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
Fix For: 0.10.0
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)
