Ce face flag-ul –from-beginning
În mod prestabilit, când pornești kafka-console-consumer.sh fără a specifica un grup existent, consumatorul se atașează la coada curentă a fluxului (offset-ul cel mai nou) și afișează doar mesajele transmise după momentul lansării comenzii. Adăugarea parametrului --from-beginning instruiește clientul să repoziționeze cursorul de citire pe cel mai mic offset disponibil pe disc pentru fiecare partiție.
Exemplu Concret: Replay complet al evenimentelor din topic
kafka-console-consumer.sh --bootstrap-server localhost:9092 \
--topic notificari-sms \
--from-beginningUtilizări frecvente
- Verificarea persistenței: Confirmarea faptului că evenimentele produse anterior au fost salvate pe disc și nu au expirat.
- Audit și depanare: Rejucarea fluxului de date pentru a reproduce erori de procesare sau inconsistențe în payload.
Întrebări & Exemple de Cod:
Flag-ul –from-beginning în kafka-console-consumerAi o nelămurire despre utilizarea comenzii
Flag-ul –from-beginning în kafka-console-consumersau 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.