问题：
Spring Kafka MessageListenerContainer
闻人嘉颖
我看到了Spring的Kafka代码，我有些怀疑：
>
如果我们将1@KafKalistener与2个主题一起使用，那么spring Kafka将创建一个MessageListenerContainer。如果我为每个主题使用单独的@KafKalistener，那么将创建2个MessageListenerContainer。
MessageListenerContainer是否意味着消费者？
请帮帮忙。
共有1个答案
曾涵育
MessageListenerContainer有两种实现--KafkaMessageListenerContainer(KMLC)和ConcurrentMessageListenerContainer(CMLC)。
CMLC只是一个或多个KMLC的包装器，其KMLC的数量由concurrency指定。
@kafkalistener始终使用CMLC。
每个KMLC都有一个使用者（和一个线程）。线程使用指定的pollTimeout持续poll()作为使用者。
主题/分区如何在KMLC中分布取决于
- 主题有多少分区
- 使用者的
partition.assignment.strategy属性
-
null
类似资料：