卡夫卡消費者對不存在抵消行爲的行爲

Question

我是卡夫卡的新手，有些東西對我來說並不清楚。

1. 卡夫卡經紀人下跌將生產商下降。
2. 卡夫卡經紀人倒下將消費者下降。
3. 如果我們從一個不存在的偏移量開始，它將被無限地擊中。

Answer 1

1. 生產者不會失敗，它會選擇另一個（生活）經紀人來生產。如果沒有其他直播經紀人，您會在製作人的回覆中收到錯誤（無論如何，它不會崩潰）。
2. 消費者不會失敗，消費者會重新平衡剩餘的（活的）分區。如果你在這個代理上有分區的複製，他們的領導將會改變。
3. 它不會卡住。這種情況下的行爲取決於您在消費者配置的auto.offset.reset中設置的內容（https://kafka.apache.org/documentation/#newconsumerconfigs）。
   如果將其設置爲earliest，則會將偏移量重置爲分區中最早可用的偏移量。
   如果您將其設置爲latest，則會將偏移量重置爲分區中最新的可用值。
   如果您將其設置爲none，它會向用戶拋出異常。

至於1 & 2 - 如果您希望生產者/消費者在這種情況下停止，您可以使用一些編碼來實現它。