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 › A Spring Boot dinamikusan állítja be a Kafka Topic vagy GroupId-jét
Nézet: 21474|Válasz: 0

[Forrás] A Spring Boot dinamikusan állítja be a Kafka Topic vagy GroupId-jét

[Linket másol]
Közzétéve 2021. 11. 14. 20:03:45 | | | |
Mikroszolgáltatások telepítésekor egy klaszterben, ha parancsokat akarunk kiadni minden alkalmazásnak, előfizetést adhatunk az alkalmazásokra Kafka témákhoz, de fontos megjegyezni, hogy különböző csoportazonosítókat kell beállítani ahhoz, hogy ugyanaz a téma minden alkalmazás fogadja.

A docker segítségével készíts egy Kafka alkalmazást a következő parancsokkal:

Megjegyzés: Cseréld le a 192.168.1.166-ot a tényleges IP-címedre

pom.xml A spring-kafka csomagot az alábbiak szerint vezessük be:


A Kafka fogyasztói konfiguráció testreszabásához hozz létre egy új KafkaConsumer fájlt az alábbiak szerint:


Hozz létre egy új fogyasztói ConfigConsumer-t, amelynek alapértelmezett konfigurációja: topic:defaultTopic,groupid:defaultGroupId, és a kód a következő:

application.properties a Kafka címének konfigurálásához:


Egy projekt elindításához az alapértelmezett alkalmazás előfizetése a következő konfiguráció:



A KafkaMessageListenerContainer az AbstractMessageListenerContainer absztrakt osztályt örökli, és a createSimpleLoggingConsumerRebalanceListener metódus adja ki a fogyasztó csoportidjét és témarészét, partícióját.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partitions assigned: [defaultTopic-0]
Dinamikusan állítsuk be a témát és a csoportidot, és a projektindítási parancs a következő:



A téma a1-re van állítva, a csoportid pedig itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partitions assigned: [a1-0]
A Spring felülírja az alapértelmezett konfigurációt a jar csomagon belül
https://www.itsvse.com/thread-10129-1-1.html

(Vége)





Előző:Lassú lekérdezések MySQL teljesítményoptimalizációhoz
Következő:Spring Boot Kafka újraindul, hogy eldobja a régi adatokat

Kapcsolódó bejegyzések
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