Zahteve: Ko se zažene aplikacija Spring Boot, se iz baze podatkov ali predpomnilnika preberejo nekatere konfiguracijske informacije, Kafka pa se uporablja za naročanje na spremembe konfiguracijskih informacij. Ker aplikacija začne z najnovejšimi informacijami o konfiguraciji, bodo sporočila o zgodovinskih posodobitvah konfiguracije Kafka brez pomena, in če uporabljate zgodovinska sporočila, boste imeli težave.
Po ponovnem zagonu aplikacije Spring Boot se pojavi vprašanje, kako zavreči stare podatke o določeni temiKafkova sporočila o zgodovini te teme niso prejetaTa? Pravzaprav je to težavo mogoče rešiti z nastavitvijo začetnega zamika, ki naročniku omogoča, da nastavi premik teme na zadnji položaj, preden se naroči na sporočilo.
Tudi če je spring.kafka.consumer.auto-offset-reset nastavljen na najnovejše, bo uporabnik prebral sporočilo iz bita zastavice, kjer je bil nazadnje potrjen kot prejemnik sporočila, kar povzroči, da bo uporabnik po ponovnem zagonu prebral veliko število sporočil, če proizvajalec pošlje veliko sporočil, ko je aplikacija zaprta.
Uporabnik med inicializacijo išče določen zamik z naslednjo kodo:
(Konec)
|
Objavljeno 2021-11-14 21:42:26
|
|
|
Najemodajalec|
Objavljeno 15. 11. 2021 ob 10:37:05
|
