Vaatimukset: Kun jousikäynnistyssovellus käynnistetään, osa konfiguraatiotiedoista luetaan tietokannasta tai välimuistista, ja Kafkaa käytetään tilaamaan konfiguraatiotietojen muutoksia. Koska sovellus alkaa uusimmista konfiguraatiotiedoista, viestit historiallisista Kafka-konfiguraatiopäivityksistä ovat merkityksettömiä, ja jos käytät historiallisia viestejä, tulee ongelmia.
Kun Spring Boot -sovellus käynnistyy uudelleen, herää kysymys siitä, miten vanhat tiedot aiheesta voi hylätäKafka-viestejä aiheen historiasta ei vastaanotetaTämä? Itse asiassa tämä ongelma voidaan ratkaista asettamalla aloitussiirtymä, jonka avulla tilaaja voi asettaa aiheen siirtymän viimeiseen paikkaan ennen viestin tilaamista.
Vaikka spring.kafka.consumer.auto-offset-reset olisi asetettu viimeisimmäksi, kuluttaja lukee viestin siitä lippubitistä, johon viesti viimeksi vahvistettiin, mikä saa kuluttajan lukemaan suuren määrän viestejä uudelleenkäynnistyksen jälkeen, jos tuottaja lähettää suuren määrän viestejä sovelluksen ollessa suljettu.
Kuluttaja etsii tarkkaa siirtymää alustuksen aikana seuraavalla koodilla:
(Loppu)
|
Julkaistu 2021-11-14 21:42:26
|
|
|
Vuokraisäntä|
Julkaistu 2021-11-15 10:37:05
|
