Acest articol este un articol oglindă al traducerii automate, vă rugăm să faceți clic aici pentru a sări la articolul original.

Architect_Programmer_Code Rețeaua Agricolă»Arhitect › Programare › Java › Spring Boot Kafka repornește pentru a elimina datele vechi
Vedere: 21274|Răspunde: 1

[Sursă] Spring Boot Kafka repornește pentru a elimina datele vechi

[Copiază linkul]
Postat la 2021-11-14 21:42:26 | | |
Cerințe: Când aplicația spring boot este lansată, unele informații de configurație vor fi citite din baza de date sau din cache, iar Kafka va fi folosit pentru a se abona la modificările de configurare. Deoarece aplicația începe cu cele mai recente informații de configurare, mesajele despre actualizările istorice de configurare Kafka vor fi inutile, iar dacă folosești mesaje istorice, vei avea probleme.

După ce aplicația Spring Boot repornește, apare o întrebare despre cum să elimini datele vechi pe un subiectMesajele Kafka pentru istoria acelui subiect nu sunt primiteAcest? De fapt, această problemă poate fi rezolvată prin setarea offset-ului de start, care permite abonatului să seteze offset-ul subiectului la ultima poziție înainte de a se abona la mesaj.

Chiar dacă spring.kafka.consumer.auto-offset-reset este setat pe cel mai târziu, consumatorul va citi mesajul de pe bitul de steag unde a fost confirmat ultima dată că a primit mesajul, ceea ce va determina consumatorul să citească un număr mare de mesaje după repornire dacă producătorul trimite un număr mare de mesaje când aplicația este închisă.

Consumatorul caută un offset specific în timpul inițializării, cu următorul cod:

(Sfârșit)





Precedent:Spring Boot setează dinamic Topic sau GroupId-ul lui Kafka
Următor:Linux analizează ieșirea jurnalului serviciului Systemd

Postări conexe
 Proprietarul| Postat la 2021-11-15 10:37:05 |
Spring Boot setează dinamic Topic sau GroupId-ul lui Kafka
https://www.itsvse.com/thread-10152-1-1.html

Sub CentOS 7, Kafka închide adesea soluțiile
https://www.itsvse.com/thread-10090-1-1.html

Valoarea auto.offset.reset a lui Kafka este explicată în detaliu
https://www.itsvse.com/thread-10017-1-1.html

Sistemul Kafka Windows se va bloca după ce a funcționat o perioadă de timp
https://www.itsvse.com/thread-9984-1-1.html

Windows Kafka ERROR Nu a reușit să curețe jurnalul pentru __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka configurează monitorizarea la distanță JMX
https://www.itsvse.com/thread-9968-1-1.html

Explicație detaliată a parametrilor de configurație Kafka
https://www.itsvse.com/thread-9965-1-1.html

Kafka setează manual offset-ul
https://www.itsvse.com/thread-9641-1-1.html

Operații Kafka pentru cozi de mesaje .NET/C# [cu cod sursă]
https://www.itsvse.com/thread-9619-1-1.html
Disclaimer:
Tot software-ul, materialele de programare sau articolele publicate de Code Farmer Network sunt destinate exclusiv scopurilor de învățare și cercetare; Conținutul de mai sus nu va fi folosit în scopuri comerciale sau ilegale, altfel utilizatorii vor suporta toate consecințele. Informațiile de pe acest site provin de pe Internet, iar disputele privind drepturile de autor nu au legătură cu acest site. Trebuie să ștergi complet conținutul de mai sus de pe calculatorul tău în termen de 24 de ore de la descărcare. Dacă îți place programul, te rugăm să susții software-ul autentic, să cumperi înregistrarea și să primești servicii autentice mai bune. Dacă există vreo încălcare, vă rugăm să ne contactați prin e-mail.
Mail To:help@itsvse.com