不同 ConcurrentMessageListenerContainer 实例上的共享线程池

Question

我有一个包含很多消费者组的用例（每个消费者组一个主题），因此我必须创建许多 ConcurrentMessageListenerContainer 实例，每个实例一个对一个 topic/consumergroup。但我希望他们共享一个公共线程池来控制 kafkaconsumer.poll 的调用以及记录的处理方式。您认为与 spring kafka 相关吗？还是我必须实现自己的版本来实例化自己的 KafakConsumers？

Answer 1

使用池不会有帮助 - 容器当前为每个消费者使用一个专用线程。不支持跨容器共享线程。