卡夫卡消费者对不存在抵消行为的行为

Question

我是卡夫卡的新手，有些东西对我来说并不清楚。

1. 卡夫卡经纪人下跌将生产商下降。
2. 卡夫卡经纪人倒下将消费者下降。
3. 如果我们从一个不存在的偏移量开始，它将被无限地击中。

Answer 1

1. 生产者不会失败，它会选择另一个（生活）经纪人来生产。如果没有其他直播经纪人，您会在制作人的回复中收到错误（无论如何，它不会崩溃）。
2. 消费者不会失败，消费者会重新平衡剩余的（活的）分区。如果你在这个代理上有分区的复制，他们的领导将会改变。
3. 它不会卡住。这种情况下的行为取决于您在消费者配置的auto.offset.reset中设置的内容（https://kafka.apache.org/documentation/#newconsumerconfigs）。
   如果将其设置为earliest，则会将偏移量重置为分区中最早可用的偏移量。
   如果您将其设置为latest，则会将偏移量重置为分区中最新的可用值。
   如果您将其设置为none，它会向用户抛出异常。

至于1 & 2 - 如果您希望生产者/消费者在这种情况下停止，您可以使用一些编码来实现它。