Dit artikel is een spiegelartikel van machinevertaling, klik hier om naar het oorspronkelijke artikel te gaan.

Architect_Programmer_Code Landbouwnetwerk»Architect › Programmeren › Java › Spring Boot Kafka start opnieuw om oude data weg te gooien
Bekijken: 21274|Antwoord: 1

[Bron] Spring Boot Kafka start opnieuw om oude data weg te gooien

[Link kopiëren]
Geplaatst op 14-11-2021 21:42:26 | | |
Vereisten: Wanneer de spring boot-applicatie wordt gestart, wordt wat configuratie-informatie uit de database of cache gelezen, en wordt Kafka gebruikt om zich te abonneren op wijzigingen in configuratiegegevens. Omdat de app begint met de nieuwste configuratie-informatie, zijn berichten over historische Kafka-configuratie-updates betekenisloos, en als je historische berichten gebruikt, krijg je problemen.

Nadat de Spring Boot-app opnieuw is opgestart, rijst er een vraag over hoe je oude data over een onderwerp kunt weggooienKafka-berichten over de geschiedenis van dat onderwerp worden niet ontvangenDit? Dit probleem kan zelfs worden opgelost door de startoffset in te stellen, waardoor de abonnee de offset van het onderwerp op de laatste positie kan zetten voordat hij zich op het bericht abonneert.

Zelfs als spring.kafka.consumer.auto-offset-reset op het nieuwste staat, zal de consument het bericht lezen van de vlagbit waar het laatst werd bevestigd dat het het bericht heeft ontvangen, waardoor de consument na het herstarten een groot aantal berichten leest als de producer een groot aantal berichten stuurt wanneer de app wordt gesloten.

De consument zoekt tijdens de initialisatie naar een specifieke offset met de volgende code:

(Einde)





Vorig:Spring Boot stelt dynamisch het onderwerp of GroupId van Kafka in
Volgend:Linux kijkt naar de loguitvoer van de SystemD-service

Gerelateerde berichten
 Huisbaas| Geplaatst op 15-11-2021 10:37:05 |
Spring Boot stelt dynamisch het onderwerp of GroupId van Kafka in
https://www.itsvse.com/thread-10152-1-1.html

Onder CentOS 7 hangt Kafka vaak oplossingen op
https://www.itsvse.com/thread-10090-1-1.html

Kafka's auto.offset.reset waarde wordt uitvoerig uitgelegd
https://www.itsvse.com/thread-10017-1-1.html

Het Kafka Windows-systeem hangt vast na een tijdlang draaien
https://www.itsvse.com/thread-9984-1-1.html

Windows Kafka FOUT Logboek niet opruimen voor __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka configureert JMX remote monitoring
https://www.itsvse.com/thread-9968-1-1.html

Gedetailleerde uitleg van Kafka-configuratieparameters
https://www.itsvse.com/thread-9965-1-1.html

Kafka stelt handmatig de offset in
https://www.itsvse.com/thread-9641-1-1.html

Kafka-operaties voor .NET/C# berichtwachtrijen [met broncode]
https://www.itsvse.com/thread-9619-1-1.html
Disclaimer:
Alle software, programmeermaterialen of artikelen die door Code Farmer Network worden gepubliceerd, zijn uitsluitend bedoeld voor leer- en onderzoeksdoeleinden; De bovenstaande inhoud mag niet worden gebruikt voor commerciële of illegale doeleinden, anders dragen gebruikers alle gevolgen. De informatie op deze site komt van het internet, en auteursrechtconflicten hebben niets met deze site te maken. Je moet bovenstaande inhoud volledig van je computer verwijderen binnen 24 uur na het downloaden. Als je het programma leuk vindt, steun dan de echte software, koop registratie en krijg betere echte diensten. Als er sprake is van een inbreuk, neem dan contact met ons op via e-mail.
Mail To:help@itsvse.com