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 dynamicky nastavuje Topic nebo GroupId Kafky
Pohled: 21474|Odpověď: 0

[Zdroj] Spring Boot dynamicky nastavuje Topic nebo GroupId Kafky

[Kopírovat odkaz]
Zveřejněno 14.11.2021 20:03:45 | | | |
Při nasazení mikroslužeb v clusteru, pokud chceme zadat příkazy všem aplikacím, můžeme aplikace přihlásit k odběru Kafka témat, ale je třeba poznamenat, že pro stejné téma je nutné nastavit různé groupID, aby všechny aplikace přijímaly stejné téma.

Použijte docker k vytvoření Kafka aplikace pomocí následujících příkazů:

Poznámka: Nahraďte 192.168.1.166 svou skutečnou IP adresou

pom.xml Představte jarní kafka balíček následovně:


Pro přizpůsobení konfigurace Kafka pro spotřebitele vytvořte nový soubor KafkaConsumer následovně:


Vytvořte nového spotřebitelského ConfigConsumer, který má výchozí konfiguraci: topic:defaultTopic,groupid:defaultGroupId a kód je následující:

application.properties pro konfiguraci adresy Kafky:


Pro zahájení projektu je výchozí konfigurace předplatné aplikace, a to následovně:



KafkaMessageListenerContainer dědí abstraktní třídu AbstractMessageListenerContainer a metoda createSimpleLoggingConsumerRebalanceListener vypíše groupid a topic partition uživatele.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: přiřazené oddíly: [defaultTopic-0]
Dynamicky nastavte téma a groupid a příkaz project start je následující:



Téma je nastaveno 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: přidělené oddíly: [a1-0]
Pružina přepisuje výchozí konfiguraci uvnitř balíčku jar
https://www.itsvse.com/thread-10129-1-1.html

(Konec)





Předchozí:Pomalé dotazy pro optimalizaci výkonu MySQL
Další:Spring Boot Kafka restartuje a vyhodí stará data

Související příspěvky
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