Denna artikel är en spegelartikel om maskinöversättning, klicka här för att hoppa till originalartikeln.

Architect_Programmer_Code Jordbruksnätverket»Arkitekt › Programmering › Java › Spring Boot Kafka startar om för att kassera gammal data
Utsikt: 21274|Svar: 1

[Källa] Spring Boot Kafka startar om för att kassera gammal data

[Kopiera länk]
Publicerad den 2021-11-14 21:42:26 | | |
Krav: När spring boot-applikationen startas kommer viss konfigurationsinformation att läsas från databasen eller cachen, och Kafka kommer att användas för att prenumerera på ändringar i konfigurationsinformation. Eftersom appen startar med den senaste konfigurationsinformationen kommer meddelanden om historiska Kafka-konfigurationsuppdateringar att vara meningslösa, och om du använder historiska meddelanden kommer du att få problem.

Efter att Spring Boot-appen startat om uppstår en fråga om hur man slänger gammal data om ett ämneKafka-meddelanden om ämnets historia tas inte emotDenna? Faktum är att detta problem kan lösas genom att sätta startoffset, vilket gör att prenumeranten kan ställa in offsetet för ämnet till sista positionen innan de prenumererar på meddelandet.

Även om spring.kafka.consumer.auto-offset-reset är inställd på senast, kommer konsumenten att läsa meddelandet från flaggbiten där den senast bekräftades ha mottagit meddelandet, vilket gör att konsumenten läser ett stort antal meddelanden efter omstart om producenten skickar många meddelanden när appen är stängd.

Konsumenten letar efter en specifik offset under initialiseringen, med följande kod:

(Slut)





Föregående:Spring Boot ställer dynamiskt in Kafkas ämne eller GroupId
Nästa:Linux tittar på loggutdata från Systemd-tjänsten

Relaterade inlägg
 Hyresvärd| Publicerad den 2021-11-15 10:37:05 |
Spring Boot ställer dynamiskt in Kafkas ämne eller GroupId
https://www.itsvse.com/thread-10152-1-1.html

Under CentOS 7 lägger Kafka ofta upp lösningar
https://www.itsvse.com/thread-10090-1-1.html

Kafkas auto.offset.reset-värde förklaras i detalj
https://www.itsvse.com/thread-10017-1-1.html

Kafka Windows-systemet kommer att hänga upp efter att ha varit igång en tid
https://www.itsvse.com/thread-9984-1-1.html

Windows Kafka FEL Misslyckades med att rensa loggen för __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka konfigurerar JMX:s fjärrövervakning
https://www.itsvse.com/thread-9968-1-1.html

Detaljerad förklaring av Kafkas konfigurationsparametrar
https://www.itsvse.com/thread-9965-1-1.html

Kafka ställer manuellt in offsetoffset
https://www.itsvse.com/thread-9641-1-1.html

Kafka-operationer för .NET/C#-meddelandeköer [med källkod]
https://www.itsvse.com/thread-9619-1-1.html
Friskrivning:
All programvara, programmeringsmaterial eller artiklar som publiceras av Code Farmer Network är endast för lärande- och forskningsändamål; Ovanstående innehåll får inte användas för kommersiella eller olagliga ändamål, annars kommer användarna att bära alla konsekvenser. Informationen på denna sida kommer från internet, och upphovsrättstvister har inget med denna sida att göra. Du måste helt radera ovanstående innehåll från din dator inom 24 timmar efter nedladdning. Om du gillar programmet, vänligen stöd äkta programvara, köp registrering och få bättre äkta tjänster. Om det finns något intrång, vänligen kontakta oss via e-post.
Mail To:help@itsvse.com