Ich habe gegoogelt und die Kafka-Dokumentation gelesen, aber ich konnte den Maximalwert eines Verbraucher-Offsets und ob es einen Offset-Wraparound nach dem Maximalwert gibt, nicht herausfinden. Ich verstehe Offset ist ein Int64-Wert, so ist Max-Wert 0xFFFFFFFFFFFFFFFF. Wenn es einen Umbruch gibt, wie geht Kafka mit dieser Situation um?
Demnach Post , der Offset wird nicht zurückgesetzt:
In diesem Moment wird kein Offset zurückgesetzt. Da der Offset ein langer ist, ist es kann für eine sehr lange Zeit dauern. Wenn Sie 1 TB pro Tag schreiben, können Sie weitermachen für etwa 4 Millionen Tage.
Außerdem können Sie immer mehr Partitionen verwenden (jede Partition hat ihre eigenen) Offset).
Wie Luciano gesagt hat, lohnt es sich wahrscheinlich nicht, sich darüber Gedanken zu machen.
Es scheint, dass dies nicht wirklich "behandelt" wird. Aber unter Berücksichtigung, dass der Offset pro Partition ist, scheint es, dass wir uns darüber keine Sorgen machen sollten:)
Siehe Ссылка
Tags und Links apache-kafka offset kafka-consumer-api