You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@inlong.apache.org by "healchow (Jira)" <ji...@apache.org> on 2021/07/19 04:48:00 UTC
[jira] [Created] (INLONG-753) Create tube consumer group failed
where the group exists
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)