Tento článek je zrcadlovým článkem o strojovém překladu, klikněte zde pro přechod na původní článek.

Architect_Programmer_Code Zemědělská síť»Architekt › Programování › Java › Spring Boot Kafka restartuje a vyhodí stará data
Pohled: 21274|Odpověď: 1

[Zdroj] Spring Boot Kafka restartuje a vyhodí stará data

[Kopírovat odkaz]
Zveřejněno 14. 11. 2021 21:42:26 | | |
Požadavky: Při spuštění aplikace spring boot budou z databáze nebo cache načteny některé konfigurační informace a Kafka se použije k odběru změn konfiguračních informací. Protože aplikace začíná s nejaktuálnějšími konfiguračními informacemi, zprávy o historických aktualizacích konfigurace Kafky budou bezvýznamné a pokud použijete historické zprávy, budete mít problémy.

Po restartu aplikace Spring Boot se objeví otázka, jak se zbavit starých dat na dané témaKafkovy zprávy o historii tohoto tématu nejsou přijatyToto? Tento problém lze vyřešit nastavením počátečního offsetu, který umožňuje odběrateli nastavit offset tématu na poslední pozici před odběrem zprávy.

I když je spring.kafka.consumer.auto-offset-reset nastaven na nejnižší, spotřebitel přečte zprávu z bitu příznaku, kde byl naposledy potvrzen jako příjemce zprávy, což způsobí, že po restartu přečte velké množství zpráv, pokud producent odešle velké množství zpráv při zavření aplikace.

Spotřebitel při inicializaci hledá specifický offset pomocí následujícího kódu:

(Konec)





Předchozí:Spring Boot dynamicky nastavuje Topic nebo GroupId Kafky
Další:Linux sleduje logický výstup služby Systemd

Související příspěvky
 Pronajímatel| Zveřejněno 15. 11. 2021 10:37:05 |
Spring Boot dynamicky nastavuje Topic nebo GroupId Kafky
https://www.itsvse.com/thread-10152-1-1.html

Pod CentOS 7 Kafka často zavěšuje řešení
https://www.itsvse.com/thread-10090-1-1.html

Podrobně vysvětlena je Kafka pro hodnotu auto.offset.reset
https://www.itsvse.com/thread-10017-1-1.html

Systém Kafka Windows se po určité době zavěsí
https://www.itsvse.com/thread-9984-1-1.html

Windows Kafka CHYBA Nepodařilo se vyčistit log pro __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka konfiguruje vzdálené monitorování JMX
https://www.itsvse.com/thread-9968-1-1.html

Podrobné vysvětlení parametrů konfigurace Kafky
https://www.itsvse.com/thread-9965-1-1.html

Kafka ručně nastavuje offset offset
https://www.itsvse.com/thread-9641-1-1.html

Operace Kafka pro fronty zpráv .NET/C# [se zdrojovým kódem]
https://www.itsvse.com/thread-9619-1-1.html
Zřeknutí se:
Veškerý software, programovací materiály nebo články publikované organizací Code Farmer Network slouží pouze k učení a výzkumu; Výše uvedený obsah nesmí být používán pro komerční ani nelegální účely, jinak nesou všechny důsledky uživatelé. Informace na tomto webu pocházejí z internetu a spory o autorská práva s tímto webem nesouvisí. Musíte výše uvedený obsah ze svého počítače zcela smazat do 24 hodin od stažení. Pokud se vám program líbí, podporujte prosím originální software, kupte si registraci a získejte lepší skutečné služby. Pokud dojde k jakémukoli porušení, kontaktujte nás prosím e-mailem.
Mail To:help@itsvse.com