Dit artikel is een spiegelartikel van machinevertaling, klik hier om naar het oorspronkelijke artikel te gaan.

Architect_Programmer_Code Landbouwnetwerk»Architect › Programmeren › Java › Spring Boot stelt dynamisch het onderwerp of GroupId van Kafka in
Bekijken: 21474|Antwoord: 0

[Bron] Spring Boot stelt dynamisch het onderwerp of GroupId van Kafka in

[Link kopiëren]
Geplaatst op 14-11-2021 20:03:45 | | | |
Bij het uitrollen van microservices in een cluster, als we commando's willen geven aan alle applicaties, kunnen we de applicaties abonneren op Kafka-onderwerpen, maar het moet worden opgemerkt dat verschillende groupIDs moeten worden ingesteld zodat hetzelfde onderwerp door alle applicaties wordt ontvangen.

Gebruik docker om een Kafka-applicatie te bouwen met de volgende commando's:

Let op: Vervang 192.168.1.166 door je echte IP-adres

pom.xml Introduceer het veer-kafka-pakket als volgt:


Om de Kafka-consumentenconfiguratie aan te passen, maak je als volgt een nieuw KafkaConsumer-bestand aan:


Maak een nieuwe consumenten-ConfigConsumer, die de standaardconfiguratie heeft: topic:defaultTopic,groupid:defaultGroupId, en de code is als volgt:

application.properties om het adres van Kafka te configureren:


Om een project te starten, is het app-abonnement de standaardconfiguratie, als volgt:



KafkaMessageListenerContainer erft de abstracte klasse AbstractMessageListenerContainer, en de createSimpleLoggingConsumerRebalanceListener-methode geeft de groupid en het onderwerp, partitie van de consument weer terug.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partitions assigned s: [defaultTopic-0]
Stel dynamisch het topic en groupid in, en het project start-commando is als volgt:



Het onderwerp wordt ingesteld op a1 en de groupid is itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partitions toegewezen: [a1-0]
Spring overschrijft de standaardconfiguratie binnen het jar-pakket
https://www.itsvse.com/thread-10129-1-1.html

(Einde)





Vorig:Langzame queries voor MySQL-prestatieoptimalisatie
Volgend:Spring Boot Kafka start opnieuw om oude data weg te gooien

Gerelateerde berichten
Disclaimer:
Alle software, programmeermaterialen of artikelen die door Code Farmer Network worden gepubliceerd, zijn uitsluitend bedoeld voor leer- en onderzoeksdoeleinden; De bovenstaande inhoud mag niet worden gebruikt voor commerciële of illegale doeleinden, anders dragen gebruikers alle gevolgen. De informatie op deze site komt van het internet, en auteursrechtconflicten hebben niets met deze site te maken. Je moet bovenstaande inhoud volledig van je computer verwijderen binnen 24 uur na het downloaden. Als je het programma leuk vindt, steun dan de echte software, koop registratie en krijg betere echte diensten. Als er sprake is van een inbreuk, neem dan contact met ons op via e-mail.
Mail To:help@itsvse.com