See artikkel on masintõlke peegelartikkel, palun klõpsake siia, et hüpata algse artikli juurde.

Vaade: 21274|Vastuse: 1

[Allikas] Spring Boot Kafka taaskäivitub, et vanu andmeid ära visata

[Kopeeri link]
Postitatud 2021-11-14 21:42:26 | | |
Nõuded: Kui kevadkäivitusrakendus käivitatakse, loetakse osa konfiguratsiooniteavet andmebaasist või vahemälust ning Kafka abil tellitakse konfiguratsiooniteabe muudatustele. Kuna rakendus algab uusima konfiguratsiooniteabega, on ajalooliste Kafka konfiguratsiooniuuenduste kohta teated mõttetud ja kui kasutad ajaloolisi sõnumeid, tekivad probleemid.

Pärast Spring Booti rakenduse taaskäivitust tekib küsimus, kuidas vanu andmeid teemal ära visataKafka sõnumeid selle teema ajaloo kohta ei jõua vastuSee? Tegelikult saab selle probleemi lahendada algusnihke määramisega, mis võimaldab tellijal enne sõnumi tellimist teema nihke viimasele positsioonile seada.

Isegi kui spring.kafka.consumer.auto-offset-reset on seatud uusimale, loeb tarbija sõnumi lipubitist, kus viimati kinnitati sõnumi saamist, mis põhjustab tarbijal pärast taaskäivitamist suure hulga sõnumite lugemist, kui tootja saadab rakenduse sulgemisel palju sõnumeid.

Tarbija otsib inisialiseerimise ajal konkreetset nihket, kasutades järgmist koodi:

(Lõpp)





Eelmine:Spring Boot seab dünaamiliselt Kafka teema või GroupId
Järgmine:Linux vaatleb Systemd teenuse logiväljundit
 Üürileandja| Postitatud 2021-11-15 10:37:05 |
Spring Boot seab dünaamiliselt Kafka teema või GroupId
https://www.itsvse.com/thread-10152-1-1.html

CentOS 7 puhul katkestab Kafka sageli lahendused
https://www.itsvse.com/thread-10090-1-1.html

Kafka auto.offset.reset väärtus on üksikasjalikult selgitatud
https://www.itsvse.com/thread-10017-1-1.html

Kafka Windowsi süsteem katkeb pärast mõnda aega töötamist
https://www.itsvse.com/thread-9984-1-1.html

Windows Kafka VIGA Ei õnnestunud __consumer_offsets logi puhastada
https://www.itsvse.com/thread-9980-1-1.html

Kafka seadistab JMX kaugjälgimise
https://www.itsvse.com/thread-9968-1-1.html

Kafka konfiguratsiooni parameetrite üksikasjalik selgitus
https://www.itsvse.com/thread-9965-1-1.html

Kafka seab nihke käsitsi
https://www.itsvse.com/thread-9641-1-1.html

Kafka operatsioonid .NET/C# sõnumijärjekordade jaoks [lähtekoodiga]
https://www.itsvse.com/thread-9619-1-1.html
Disclaimer:
Kõik Code Farmer Networki poolt avaldatud tarkvara, programmeerimismaterjalid või artiklid on mõeldud ainult õppimiseks ja uurimistööks; Ülaltoodud sisu ei tohi kasutada ärilistel ega ebaseaduslikel eesmärkidel, vastasel juhul kannavad kasutajad kõik tagajärjed. Selle saidi info pärineb internetist ning autoriõiguste vaidlused ei ole selle saidiga seotud. Ülaltoodud sisu tuleb oma arvutist täielikult kustutada 24 tunni jooksul pärast allalaadimist. Kui sulle programm meeldib, palun toeta originaaltarkvara, osta registreerimist ja saa paremaid ehtsaid teenuseid. Kui esineb rikkumist, palun võtke meiega ühendust e-posti teel.

Mail To:help@itsvse.com