Nou Generator de prompt AI — scrie prompturi mai bune pentru ChatGPT, Claude și Gemini →

auto.offset.reset: Strategia de Pornire a Consumatorului în Apache Kafka

Stabilește comportamentul consumatorului atunci când nu există un offset comis anterior salvat în cluster.

Sintaxă
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); // earliest, latest, none

Ce rezolvă auto.offset.reset

Când o aplicație pornește pentru prima dată cu un group.id nou sau dacă offset-ul salvat anterior a fost șters din cauza expirării retenției pe broker, această setare indică de unde trebuie să înceapă citirea.

Exemplu Concret: Citire de la începutul topicului
Properties props = new Properties();
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");

Opțiuni disponibile

  • earliest: Consumatorul începe de la cel mai vechi mesaj valid existent pe disc.
  • latest: Consumatorul ignoră toate mesajele vechi și începe doar de la evenimentele noi care sosesc după pornirea sa.
  • none: Aruncă o excepție imediată dacă nu găsește un offset înregistrat anterior pentru grup.
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: auto.offset.reset: Strategia de Pornire a Consumatorului

Ai o nelămurire despre utilizarea comenzii auto.offset.reset: Strategia de Pornire a Consumatorului 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.