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

Question

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

标签： spring-kafka

Answer 1

使用池无济于事——容器当前为每个消费者使用一个专用线程。不支持跨容器共享线程。