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

Architect_Programmer_Code Poľnohospodárska sieť»Architekt › Programovanie › Jáva › Spring Boot dynamicky nastavuje Topic alebo GroupId Kafku
Pohľad: 21474|Odpoveď: 0

[Zdroj] Spring Boot dynamicky nastavuje Topic alebo GroupId Kafku

[Kopírovať odkaz]
Zverejnené 14. 11. 2021 20:03:45 | | | |
Pri nasadzovaní mikroslužieb v klastri, ak chceme vydávať príkazy všetkým aplikáciám, môžeme aplikácie prihlásiť na odber Kafka tém, ale treba poznamenať, že pre prijímanie tej istej témy do všetkých aplikácií je potrebné nastaviť rôzne groupID.

Použite docker na zostavenie Kafka aplikácie pomocou nasledujúcich príkazov:

Poznámka: Nahraďte 192.168.1.166 vašou skutočnou IP adresou

pom.xml Predstavte balík spring-kafka nasledovne:


Na prispôsobenie konfigurácie Kafka Consumer vytvorte nový súbor KafkaConsumer nasledovne:


Vytvorte nový spotrebiteľský ConfigConsumer, ktorý má predvolenú konfiguráciu: topic:defaultTopic,groupid:defaultGroupId a kód je nasledovný:

application.properties na konfiguráciu adresy Kafka:


Na spustenie projektu je predplatné aplikácie predvolenou konfiguráciou, nasledovne:



KafkaMessageListenerContainer zdedí abstraktnú triedu AbstractMessageListenerContainer a metóda createSimpleLoggingConsumerRebalanceListener generuje groupid a tému používateľa s partíciou.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partitions assigned: [defaultTopic-0]
Dynamicky nastavte tému a groupid a príkaz project start je nasledovný:



Téma je nastavená na a1 a groupid je itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: pridelené partície: [a1-0]
Pružina prepisuje predvolenú konfiguráciu vo vnútri balíka jar
https://www.itsvse.com/thread-10129-1-1.html

(Koniec)





Predchádzajúci:Pomalé dotazy na optimalizáciu výkonu MySQL
Budúci:Spring Boot Kafka reštartuje, aby zbavil staré dáta

Súvisiace príspevky
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