Nag*_*sha 7 apache-kafka rebalancing
我已将 Kafka 提交策略设置为最新且缺少前几条消息。如果我在开始将消息发送到输入主题之前休眠 20 秒，则一切都按预期工作。我不确定问题是否与消费者花费很长时间进行分区重新平衡有关。有没有办法在开始轮询之前知道消费者是否准备好？
小智 0
如果您的策略设置为最新（如果没有先前提交的偏移量，该策略就会生效），但您没有先前提交的偏移量，那么您不应该担心“丢失”消息，因为您告诉 Kafka 不要关心以下消息：已“提前”发送给准备就绪的消费者。
如果您关心“先前”消息，则应将策略设置为最早。
无论如何，无论策略如何，您看到的行为都是暂时的，即一旦提交的偏移量保存在 Kafka 中，每次重新启动时，消费者都会从之前离开的地方开始
| 归档时间： |
|
| 查看次数： |
6084 次 |
| 最近记录： |