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