我有这个方法
@KafkaListener(topics={"one", "two", "three"})
public void listen(String message) { ...}
侦听器容器如何独立于主题和分区仅示例化一个使用者。
例如,如果我有以下分区:
one-0
one-1
two-0
three-0
three-1
有没有一种方法可以将所有这些分区分配给同一个使用者?是 ConcurrentKafkaListenerContainerFactory
的并发值设置为1就足够了吗?
1条答案
按热度按时间a8jjtwal1#
这正是默认情况下(concurrency=1,默认值)将得到的结果。
注意信息日志
Partitions assigned ...
.