RapperCL commented on issue #5232: URL: https://github.com/apache/rocketmq/issues/5232#issuecomment-1264414284
> Maybe, it's not a good idea. Consumer can setAllocateMessageQueueStrategy(); > AllocateMessageQueueStrategy is Intreface , you can implement it by yourself > `DefaultLitePullConsumer litePullConsumer = new DefaultLitePullConsumer(MixAll.DEFAULT_CONSUMER_GROUP); litePullConsumer.setAllocateMessageQueueStrategy(); ` > For users , it will make trouble for users if it is implemented by other way. If use spi mechanisms, then only need to modify the RMQ corresponding configuration file, or by providing in current RMQ ServiceProvider. LoadClass, only load the first class, in this way, we can directly in the current project to add the corresponding configuration class can, need not modify the source code -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
