apache-kafka - 是否可以控制 Spring Kafka 消息侦听器在其分配的分区之间切换的频率？

Question

当 Spring Kafka MessageListener 使用来自多个分区的消息时，它会继续处理来自一个分区的消息，直到没有更多消息，然后才继续处理下一个分区。（根据我的观察）

是否可以设置消息/批次的最大数量并告诉侦听器更快地切换到下一个分区而不是稍后？

这将提高公平性并均匀地消耗所有分配的分区。

Answer 1

更快地切换到下一个分区，从所有分配的分区中均匀消耗

我认为卡夫卡对此没有任何属性。卡夫卡消费者配置

有点奇怪。您可以将 Kafka 中的分区副本视为日志文件。您的消费者poll在一个线程中运行，为了获得更好的性能，它应该从一个文件中消费，下一个poll将从另一个文件中消费，而不是分开它并从每个分区中平均消费poll，对吧？最终，您仍然需要使用该主题的所有消息。