Denne artikel er en spejling af maskinoversættelse, klik venligst her for at springe til den oprindelige artikel.

Architect_Programmer_Code Landbrugsnetværk»Arkitekt › Programmering › Java › Spring Boot sætter dynamisk Topic eller GroupId for Kafka
Udsigt: 21474|Svar: 0

[Kilde] Spring Boot sætter dynamisk Topic eller GroupId for Kafka

[Kopier link]
Opslået på 14/11/2021 20.03.45 | | | |
Når vi implementerer mikroservices i en klynge, hvis vi vil udstede kommandoer til alle applikationer, kan vi abonnere applikationerne på Kafka-emner, men det skal bemærkes, at forskellige gruppe-ID'er skal sættes for at det samme emne kan modtages af alle applikationer.

Brug docker til at bygge en Kafka-applikation med følgende kommandoer:

Bemærk: Erstat 192.168.1.166 med din faktiske IP-adresse

pom.xml Introducer fjeder-kafka-pakken som følger:


For at tilpasse Kafka-forbrugerkonfigurationen skal du oprette en ny KafkaConsumer-fil som følger:


Opret en ny forbruger-ConfigConsumer, som har standardkonfigurationen: topic:defaultTopic,groupid:defaultGroupId, og koden er som følger:

application.properties til at konfigurere adressen på Kafka:


For at starte et projekt er app-abonnementet standardkonfigurationen, som følger:



KafkaMessageListenerContainer arver abstraktklassen AbstractMessageListenerContainer, og createSimpleLoggingConsumerRebalanceListener-metoden udgiver forbrugerens groupid og emne, partition.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partitioner tildelt: [defaultTopic-0]
Sæt dynamisk topic og groupid, og projektstart-kommandoen er som følger:



Emnet sættes til a1, og groupiden er itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partitioner tildelt: [a1-0]
Fjeder overskriver standardkonfigurationen inde i jar-pakken
https://www.itsvse.com/thread-10129-1-1.html

(Slut)





Tidligere:Langsomme forespørgsler til MySQL-ydelsesoptimering
Næste:Spring Boot Kafka genstarter for at kassere gamle data

Relaterede indlæg
Ansvarsfraskrivelse:
Al software, programmeringsmaterialer eller artikler udgivet af Code Farmer Network er kun til lærings- og forskningsformål; Ovenstående indhold må ikke bruges til kommercielle eller ulovlige formål, ellers skal brugerne bære alle konsekvenser. Oplysningerne på dette site kommer fra internettet, og ophavsretstvister har intet med dette site at gøre. Du skal slette ovenstående indhold fuldstændigt fra din computer inden for 24 timer efter download. Hvis du kan lide programmet, så understøt venligst ægte software, køb registrering og få bedre ægte tjenester. Hvis der er nogen overtrædelse, bedes du kontakte os via e-mail.
Mail To:help@itsvse.com