Opțiunea –to-earliest la Resetarea Offset-urilor în Apache Kafka

Deplasează offset-urile grupului direct la cel mai mic offset valid disponibil pe disc pentru fiecare partiție.

Sintaxă
--reset-offsets --to-earliest --topic <nume>

Cum funcționează opțiunea –to-earliest

Opțiunea --to-earliest mută cursorul de citire al grupului pe primul mesaj păstrat încă pe broker în funcție de politicile de retenție (ex: retention.ms). Aceasta asigură că la repornirea consumatorilor, întregul set de date istorice va fi re-analizat de la zero.

Exemplu Concret: Reprocesare integrală
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
  --group analytics-rebuild \
  --reset-offsets \
  --to-earliest \
  --topic evenimente-analytics \
  --execute
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: Opțiunea –to-earliest la Resetarea Offset-urilor

Ai o nelămurire despre utilizarea comenzii Opțiunea –to-earliest la Resetarea Offset-urilor sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.