java - 如何提高 Kafk 的消费者分区重新分配时间

Question

我们正在使用 Kafka 1.11 我们的系统挑战是在非停机时间 SLA 上保持低延迟

我们使用 kafka 作为我们的消息代理，在我们的部署过程中，我们遇到了延迟峰值。

A - 主题 X 的生产者（有 2 个分区）

B,C - 主题 X 的消费者

当关闭消费者 B 发送到 B 的分区的消息在重新分区阶段被延迟（大约 1 秒）直到分配给消费者 A

当我们关闭消费者时，你能告诉我们如何提升重新分区阶段以最小化这种延迟吗？

谢谢

标签： javaapache-kafkakafka-consumer-apikafka-producer-api