Denne artikkelen er en speilartikkel om maskinoversettelse, vennligst klikk her for å hoppe til originalartikkelen.

Utsikt: 21274|Svare: 1

[Kilde] Spring Boot Kafka starter på nytt for å forkaste gamle data

[Kopier lenke]
Publisert 2021-11-14 21:42:26 | | |
Krav: Når spring boot-applikasjonen startes, vil noe konfigurasjonsinformasjon bli lest fra databasen eller cachen, og Kafka vil bli brukt til å abonnere på endringer i konfigurasjonsinformasjon. Siden appen starter med den nyeste konfigurasjonsinformasjonen, vil meldinger om historiske Kafka-konfigurasjonsoppdateringer være meningsløse, og hvis du bruker historiske meldinger, vil du få problemer.

Etter at Spring Boot-appen starter på nytt, oppstår det et spørsmål om hvordan man kan kvitte seg med gamle data om et temaKafka-meldinger om historien til det temaet mottas ikkeDenne? Faktisk kan dette problemet løses ved å sette startforskyvningen, som lar abonnenten sette forskyvningen av emnet til siste posisjon før meldingen abonnerer.

Selv om spring.kafka.consumer.auto-offset-reset er satt til sist, vil forbrukeren lese meldingen fra flaggbiten der den sist ble bekreftet å ha mottatt meldingen, noe som vil føre til at forbrukeren leser et stort antall meldinger etter omstart hvis produsenten sender mange meldinger når appen lukkes.

Forbrukeren ser etter en spesifikk offset under initialiseringen, med følgende kode:

(Slutt)





Foregående:Spring Boot setter dynamisk Topic eller GroupId til Kafka
Neste:Linux ser på loggutgangen fra Systemd-tjenesten
 Vert| Publisert 2021-11-15 10:37:05 |
Spring Boot setter dynamisk Topic eller GroupId til Kafka
https://www.itsvse.com/thread-10152-1-1.html

Under CentOS 7 henger Kafka ofte opp løsninger
https://www.itsvse.com/thread-10090-1-1.html

Kafkas auto.offset.reset-verdi forklares i detalj
https://www.itsvse.com/thread-10017-1-1.html

Kafka Windows-systemet henger seg opp etter å ha kjørt en periode
https://www.itsvse.com/thread-9984-1-1.html

Windows Kafka FEIL Klarte ikke å rydde loggen for __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka konfigurerer JMX fjernovervåking
https://www.itsvse.com/thread-9968-1-1.html

Detaljert forklaring av Kafkas konfigurasjonsparametere
https://www.itsvse.com/thread-9965-1-1.html

Kafka setter offset-offset manuelt
https://www.itsvse.com/thread-9641-1-1.html

Kafka-operasjoner for .NET/C#-meldingskøer [med kildekode]
https://www.itsvse.com/thread-9619-1-1.html
Ansvarsfraskrivelse:
All programvare, programmeringsmateriell eller artikler publisert av Code Farmer Network er kun for lærings- og forskningsformål; Innholdet ovenfor skal ikke brukes til kommersielle eller ulovlige formål, ellers skal brukerne bære alle konsekvenser. Informasjonen på dette nettstedet kommer fra Internett, og opphavsrettstvister har ingenting med dette nettstedet å gjøre. Du må fullstendig slette innholdet ovenfor fra datamaskinen din innen 24 timer etter nedlasting. Hvis du liker programmet, vennligst støtt ekte programvare, kjøp registrering, og få bedre ekte tjenester. Hvis det foreligger noen krenkelse, vennligst kontakt oss på e-post.

Mail To:help@itsvse.com