Reikalavimai: Paleidus spyruoklinės įkrovos programą, tam tikra konfigūracijos informacija bus nuskaityta iš duomenų bazės ar talpyklos, o Kafka bus naudojama konfigūracijos informacijos pakeitimams prenumeruoti. Kadangi programa paleidžiama su naujausia konfigūracijos informacija, pranešimai apie istorinius Kafkos konfigūracijos atnaujinimus bus beprasmiai, o jei naudosite istorinius pranešimus, turėsite problemų.
Iš naujo paleidus "Spring Boot" programą, kyla klausimas, kaip atsisakyti senų duomenų šia temaKafkos pranešimai apie šios temos istoriją negaunamiŠis? Tiesą sakant, šią problemą galima išspręsti nustatant pradinį poslinkį, kuris leidžia abonentui nustatyti temos poslinkį į paskutinę padėtį prieš užsiprenumeruojant pranešimą.
Net jei spring.kafka.consumer.auto-offset-reset nustatytas kaip naujausias, vartotojas perskaitys pranešimą iš vėliavėlės bito, kuriame paskutinį kartą buvo patvirtinta, kad gavo pranešimą, todėl vartotojas perskaitys daug pranešimų paleidus iš naujo, jei gamintojas išsiunčia daug pranešimų, kai programa uždaryta.
Inicijavimo metu vartotojas ieško konkretaus poslinkio su tokiu kodu:
(Pabaiga)
|
Publikuota: 2021-11-14 21:42:26
|
|
|
Savininkas|
Publikuota: 2021-11-15 10:37:05
|
