Ce face comanda kafka-consumer-groups.sh –reset-offsets
Când o aplicație are un bug în logica de procesare a datelor și trebuie să reia procesarea de la început sau de la o anumită dată, comanda --reset-offsets suprascrie valorile salvate în __consumer_offsets. Consumatorii trebuie să fie opriți (starea grupului trebuie să fie Empty) în timpul execuției.
Exemplu Concret: Resetarea la cel mai vechi offset cu validare prealabilă
# Pasul 1: Simularea modificării (Dry Run)
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--group serviciu-facturare \
--reset-offsets \
--to-earliest \
--topic comenzi \
--dry-run
# Pasul 2: Aplicarea modificării reale
kafka-consumer-groups.sh --bootstrap-server localhost:9092 \
--group serviciu-facturare \
--reset-offsets \
--to-earliest \
--topic comenzi \
--execute
Întrebări & Exemple de Cod:
kafka-consumer-groups.sh –reset-offsets: Reprocesarea DatelorAi o nelămurire despre utilizarea comenzii
kafka-consumer-groups.sh –reset-offsets: Reprocesarea Datelorsau 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.