Ez a cikk egy tükör gépi fordítás, kérjük, kattintson ide, hogy ugorjon az eredeti cikkre.

Architect_Programmer_Code Mezőgazdasági Hálózat»Építész › Programozás › Jáva › Spring Boot Kafka újraindul, hogy eldobja a régi adatokat
Nézet: 21274|Válasz: 1

[Forrás] Spring Boot Kafka újraindul, hogy eldobja a régi adatokat

[Linket másol]
Közzétéve: 2021-11-14 21:42:26 | | |
Követelmények: Amikor a spring boot alkalmazás elindul, néhány konfigurációs információt olvasnak az adatbázisból vagy gyorstárból, és a Kafka segítségével feliratkozik a konfigurációs információk módosításaira. Mivel az alkalmazás a legfrissebb konfigurációs információkkal indul, a történelmi Kafka konfigurációs frissítésekről szóló üzenetek értelmetlenek lesznek, és ha történelmi üzeneteket használsz, problémák lesznek.

Miután a Spring Boot alkalmazás újraindul, felmerül a kérdés, hogyan lehet eltörölni a régi adatokat egy témábanA téma történetéről szóló Kafka üzenetek nem érkeznek megEz? Valójában ezt a problémát megoldhatja a kezdő eltolás beállításával, amely lehetővé teszi az előfizető számára, hogy a téma utolsó pozícióját állítsa az üzenet előrendelése előtt.

Még ha a spring.kafka.consumer.auto-offset-reset leglegfrissebb állapotra is van állítva, a fogyasztó az üzenetet az utoljára megkapta zászlóbitből olvassa el, ami miatt a felhasználó újraindítás után sok üzenetet olvas, ha a gyártó sok üzenetet küld az alkalmazás zárásakor.

A fogyasztó egy adott elmozdulatot keres az inicializáció során, a következő kóddal:

(Vége)





Előző:A Spring Boot dinamikusan állítja be a Kafka Topic vagy GroupId-jét
Következő:A Linux a Systemd szolgáltatás napló kimenetét vizsgálja

Kapcsolódó bejegyzések
 Háziúr| Közzétéve: 2021-11-15 10:37:05 |
A Spring Boot dinamikusan állítja be a Kafka Topic vagy GroupId-jét
https://www.itsvse.com/thread-10152-1-1.html

CentOS 7 alatt a Kafka gyakran leteszi a megoldásokat
https://www.itsvse.com/thread-10090-1-1.html

A Kafka auto.offset.reset értéke részletesen ismertetve van
https://www.itsvse.com/thread-10017-1-1.html

A Kafka Windows rendszer egy ideig leáll a lejárat után
https://www.itsvse.com/thread-9984-1-1.html

Windows Kafka HIBA Nem sikerült tisztítani a naplót __consumer_offsets
https://www.itsvse.com/thread-9980-1-1.html

Kafka konfigurálja a JMX távoli monitorozását
https://www.itsvse.com/thread-9968-1-1.html

Részletes magyarázat a Kafka konfigurációs paraméterekről
https://www.itsvse.com/thread-9965-1-1.html

Kafka manuálisan állítja be az elolást
https://www.itsvse.com/thread-9641-1-1.html

Kafka műveletek .NET/C# üzenetsorokhoz [forráskóddal]
https://www.itsvse.com/thread-9619-1-1.html
Lemondás:
A Code Farmer Network által közzétett összes szoftver, programozási anyag vagy cikk kizárólag tanulási és kutatási célokra szolgál; A fenti tartalmat nem szabad kereskedelmi vagy illegális célokra használni, különben a felhasználók viselik az összes következményet. Az oldalon található információk az internetről származnak, és a szerzői jogi vitáknak semmi köze ehhez az oldalhoz. A fenti tartalmat a letöltés után 24 órán belül teljesen törölni kell a számítógépéről. Ha tetszik a program, kérjük, támogassa a valódi szoftvert, vásároljon regisztrációt, és szerezzen jobb hiteles szolgáltatásokat. Ha bármilyen jogsértés történik, kérjük, vegye fel velünk a kapcsolatot e-mailben.
Mail To:help@itsvse.com