kafka多个消费者在收听多个主题

2skhul33  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(428)

我们正在开发一个应用程序,在这个应用程序中,我们要听Kafka的多个主题。所有主题都有一个分区。所有的主题名都有一个共同的前缀,例如“test-x”,“test-y”,这样我们就可以使用spring了 topicPattern 为了它。
我们想编写一个javaspring消费者,它使用 regexp 图案。我们的想法是,我们可以运行同一个消费者(属于同一个组)的多个示例,kafka将为不同的消费者分发来自不同主题的消息。
然而,这似乎不起作用。即使我们运行多个使用者示例,也只有一个使用者从所有主题获取消息。如果我们在主题中创建了多个分区,那么它可以工作,但这是我们没有的。
有什么我们不明白的吗?提前谢谢。

3zwtqj6y

3zwtqj6y1#

kafka将主题内的分区分布在使用者组(具有相同group.id的使用者)之间。由于主题只有分区,因此使用者组中只有一个使用者会收到消息。

相关问题