@kafkalistener和一个消费者

mwkjh3gx  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(359)

我有这个方法

@KafkaListener(topics={"one", "two", "three"})
public void listen(String message) { ...}

侦听器容器如何独立于主题和分区仅示例化一个使用者。
例如,如果我有以下分区:

one-0
one-1
two-0
three-0
three-1

有没有一种方法可以将所有这些分区分配给同一个使用者?是 ConcurrentKafkaListenerContainerFactory 的并发值设置为1就足够了吗?

a8jjtwal

a8jjtwal1#

这正是默认情况下(concurrency=1,默认值)将得到的结果。
注意信息日志 Partitions assigned ... .

相关问题