Tento článok je zrkadlovým článkom o strojovom preklade, kliknite sem pre prechod na pôvodný článok.

Pohľad: 21274|Odpoveď: 1

[Zdroj] Spring Boot Kafka reštartuje, aby zbavil staré dáta

[Kopírovať odkaz]
Zverejnené 2021-11-14 21:42:26 | | |
Požiadavky: Keď sa spustí aplikácia spring boot, niektoré konfiguračné informácie sa prečítajú z databázy alebo cache a Kafka sa použije na prihlásenie na zmeny konfiguračných informácií. Keďže aplikácia začína s najnovšími konfiguračnými informáciami, správy o historických aktualizáciách konfigurácie Kafka budú bezvýznamné a ak použijete historické správy, budete mať problémy.

Po reštarte aplikácie Spring Boot sa objavuje otázka, ako sa zbaviť starých dát o danej témeKafkovské správy o histórii tejto témy sa neprijímajúToto? V skutočnosti sa tento problém dá vyriešiť nastavením počiatočného offsetu, ktorý umožňuje odberateľovi nastaviť offset témy na poslednú pozíciu pred prihlásením sa na správu.

Aj keď je spring.kafka.consumer.auto-offset-reset nastavený na najnovšie, spotrebiteľ prečíta správu z príznakového bitu, kde bol naposledy potvrdený prijatie správy, čo spôsobí, že po reštarte prečíta veľké množstvo správ, ak producent pošle veľké množstvo správ pri zatvorení aplikácie.

Spotrebiteľ hľadá špecifický offset počas inicializacie s nasledujúcim kódom:

(Koniec)





Predchádzajúci:Spring Boot dynamicky nastavuje Topic alebo GroupId Kafku
Budúci:Linux sleduje výstup logu služby Systemd
 Prenajímateľ| Zverejnené 15.11.2021 10:37:05 |
Spring Boot dynamicky nastavuje Topic alebo GroupId Kafku
https://www.itsvse.com/thread-10152-1-1.html

Pod CentOS 7 Kafka často odkladá riešenia
https://www.itsvse.com/thread-10090-1-1.html

Podrobne vysvetlená je hodnota auto.offset.reset v Kafke
https://www.itsvse.com/thread-10017-1-1.html

Systém Kafka Windows sa po určitom čase zasekne
https://www.itsvse.com/thread-9984-1-1.html

Windows Kafka CHYBA Nepodarilo sa vyčistiť logy pre __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka konfiguruje diaľkové monitorovanie JMX
https://www.itsvse.com/thread-9968-1-1.html

Podrobné vysvetlenie parametrov konfigurácie Kafka
https://www.itsvse.com/thread-9965-1-1.html

Kafka manuálne nastavuje offsetový offset
https://www.itsvse.com/thread-9641-1-1.html

Kafka operácie pre .NET/C# fronty správ [so zdrojovým kódom]
https://www.itsvse.com/thread-9619-1-1.html
Vyhlásenie:
Všetok softvér, programovacie materiály alebo články publikované spoločnosťou Code Farmer Network slúžia len na vzdelávacie a výskumné účely; Vyššie uvedený obsah nesmie byť použitý na komerčné alebo nezákonné účely, inak nesú všetky následky používateľmi. Informácie na tejto stránke pochádzajú z internetu a spory o autorské práva s touto stránkou nesúvisia. Musíte úplne vymazať vyššie uvedený obsah zo svojho počítača do 24 hodín od stiahnutia. Ak sa vám program páči, podporte originálny softvér, zakúpte si registráciu a získajte lepšie originálne služby. Ak dôjde k akémukoľvek porušeniu, kontaktujte nás prosím e-mailom.

Mail To:help@itsvse.com