如何提高 MultiTopicsConsumer 的异步通知能力

Consumer 使用一个 externalPinnedExecutor 进行异步通知,假设有7个topic:

【方案一】构造 7 个 consumer
【方案二】构造一个 1 个 MultiTopicsConsumerImpl,传入 7 个 topic

如果 numListenerThreads 是 10,方案一的异步通知能力远大于方案二,因为方案一可以使用 7 个 externalPinnedExecutor。

因为想在 triggerListener 中做自定义协议解码工作,请问有什么方式能提高方案二的异步通知能力吗?

你好,MultiTopicsConsumer在订阅的时候,如果你给它传入7个topic,那么它会在内部创建7个Consumer,相应的也会创建7个externalPinnedExecutor。
所以这对于方案一和方案二是相同的。

感谢回答,又看了下代码确实如此。 但压测下来方案一的消费能力远高于方案二,目前还没发现瓶颈在哪