Ich googelte und las die Kafka-Dokumentation, aber ich konnte den maximalen Wert eines Consumer-Offsets nicht herausfinden und ob es einen Offset-Wraparound nach dem Maximalwert gibt. Ich verstehe Offset ist ein Int64-Wert, so ist Max-Wert 0xFFFFFFFFFFFFFFFF. Wenn es einen Umbruch gibt, wie geht Kafka mit dieser Situation um?Kafka Verbraucher Offset Max Wert?
7
A
Antwort
17
Nach dieser post Versatz nicht zurückgesetzt:
Wir Rollback Offset in diesem Moment nicht. Da der Offset ein langer ist, kann er für eine sehr lange Zeit dauern. Wenn Sie 1 TB pro Tag schreiben, können Sie für etwa 4 Millionen Tage weitermachen.
Außerdem können Sie immer mehr Partitionen verwenden (jede Partition hat ihren eigenen Offset).
So wie Luciano sagte, wahrscheinlich nicht die Mühe wert, sich zu sorgen.
2
Es scheint, dass dies nicht wirklich "behandelt" wird. Aber unter Berücksichtigung, dass die pro Partition versetzt ist, wie es scheint dies etwas ist, wir sollten sich keine Sorgen über
:)Bitte sehen http://search-hadoop.com/m/uyzND1uRn8D1sSH322/rollover/v=threaded
Yup. Genau wie Y2K :) – Nick