Skip to content
New issue

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

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

Already on GitHub? # to your account

需要有重启consumer操作接口 #6

Open
cnhaicao opened this issue May 2, 2019 · 0 comments
Open

需要有重启consumer操作接口 #6

cnhaicao opened this issue May 2, 2019 · 0 comments

Comments

@cnhaicao
Copy link

cnhaicao commented May 2, 2019

建议ConsumerOperator是否增加重启接口,场景经常需要动态重新配置consumer消费线程,
consuner.shutdown后无法配置并发消费线程,然后重新执行start,所以只能先执行consumer.shutdown再重新创建新的cosnumer,目前的代码是一个topic一个consumer,所以,我在ConsumerOperator中增加了一个reConfig(String topic)方法,实现我的需求,我觉得这个需求很普遍,但无论是您这个starter还是官网的rocketmq-spring均未实现此需求。

# for free to join this conversation on GitHub. Already have an account? # to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant