Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Question]creating too many RocketMQ connections #4629

Open
1 task done
zscomehuyue opened this issue Dec 8, 2023 · 4 comments
Open
1 task done

[Question]creating too many RocketMQ connections #4629

zscomehuyue opened this issue Dec 8, 2023 · 4 comments
Labels
question Further information is requested Stale

Comments

@zscomehuyue
Copy link

Search before asking

  • I had searched in the issues and found no similar issues.

Question

A project will have many consumer groups, which will create a lot of clients (including pubs and subs), as well as many ClientGroupWrappers, producers (can they be shared?), consumers, and broadcasts (why do they need to be created? I don't need to);

@zscomehuyue zscomehuyue added the question Further information is requested label Dec 8, 2023
@zscomehuyue zscomehuyue changed the title [creating too many RocketMQ connections] [Question]creating too many RocketMQ connections Dec 8, 2023
@pandaapo
Copy link
Member

pandaapo commented Dec 9, 2023

To be honest, I don't fully grasp the situation described in this issue, but I still want to learn as much as possible. For instance, what does 'broadcasts' refer to?

@zscomehuyue
Copy link
Author

  1. 一个项目会很多的消费组,这样会创建很多的client(包含pub,sub),一个group创建一个ClientGroupWrapper,而一个ClientGroupWrapper,创建启动3个连接:proudcer(可以共享吗?),persistentMsgConsumer,broadCastMsgConsumer(为何需要创建那?我又不用);而该group的sub类型是SubscriptionMode.CLUSTERING,并不需要broadCastMsgConsumer,但是默认还是创建了该连接;

@xwm1992
Copy link
Contributor

xwm1992 commented Dec 11, 2023

  1. 一个项目会很多的消费组,这样会创建很多的client(包含pub,sub),一个group创建一个ClientGroupWrapper,而一个ClientGroupWrapper,创建启动3个连接:proudcer(可以共享吗?),persistentMsgConsumer,broadCastMsgConsumer(为何需要创建那?我又不用);而该group的sub类型是SubscriptionMode.CLUSTERING,并不需要broadCastMsgConsumer,但是默认还是创建了该连接;

1.目前是组代理的模式,一个组,共享一个rocketmq client
2.目前在做消费方建连的时候会初始化producer\persistConsumer\broadCastConsumer,是为了减少消费者的冷启动问题。

Copy link
Contributor

github-actions bot commented Apr 6, 2024

It has been 90 days since the last activity on this issue. Apache EventMesh values the voices of the community. Please don't hesitate to share your latest insights on this matter at any time, as the community is more than willing to engage in discussions regarding the development and optimization directions of this feature.

If you feel that your issue has been resolved, please feel free to close it. Should you have any additional information to share, you are welcome to reopen this issue.

@github-actions github-actions bot added the Stale label Apr 6, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
question Further information is requested Stale
Projects
None yet
Development

No branches or pull requests

3 participants