多分区上的Spring Kafka和轮询策略

Question

假设我有一个有4个分区的主题。我使用@KafkaListener注释使用spring kafka微服务消费记录。这个微服务是固定的，我有两个实例。然后将每个实例插入两个分区。

我观察到，当我需要赶上延迟时，实例会停留在它所在的分区上，并让第二个分区累积延迟。当我们停止生成消息并且第一个分区上的延迟被完全消耗时，它将只切换到第二个分区。

我的应用程序中的消费顺序只是部分重要。我的意思是，我可以以不同的顺序处理它们，但我不能让消息在分区中停留太久。

简单的解决方案是有四个docker实例，一切都很好。

当KafkaListener插入到多个分区时，sping-kafka中是否有一些属性允许我们更改轮询策略。这个想法是，它将在每次轮询时轮询分配给每个分区的轮询

谢谢你的阅读！

Answer 1

您可以将每个实例上的使用者（侦听器容器）并发性设置为2；这样，您将在2个实例中拥有4个使用者。

有了Spring Boot，这就是spring。Kafka。消费者并发性。如果要创建自己的工厂，请直接设置属性。