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?
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.
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