Denne artikkelen er en speilartikkel om maskinoversettelse, vennligst klikk her for å hoppe til originalartikkelen.

Architect_Programmer_Code Landbruksnettverket»Arkitekt › Programmering › Java › Spring Boot setter dynamisk Topic eller GroupId til Kafka
Utsikt: 21474|Svare: 0

[Kilde] Spring Boot setter dynamisk Topic eller GroupId til Kafka

[Kopier lenke]
Publisert på 14.11.2021 20:03:45 | | | |
Når vi distribuerer mikrotjenester i en klynge, hvis vi vil gi kommandoer til alle applikasjoner, kan vi abonnere applikasjonene på Kafka-emner, men det bør bemerkes at forskjellige gruppe-IDer må settes for at samme emne skal mottas av alle applikasjoner.

Bruk docker til å bygge en Kafka-applikasjon med følgende kommandoer:

Merk: Erstatt 192.168.1.166 med din faktiske IP-adresse

pom.xml Introduser fjær-kafka-pakken som følger:


For å tilpasse Kafka-forbrukerkonfigurasjonen, opprett en ny KafkaConsumer-fil som følger:


Opprett en ny forbruker-ConfigConsumer, som har standardkonfigurasjonen: topic:defaultTopic,groupid:defaultGroupId, og koden er som følger:

application.properties for å konfigurere adressen til Kafka:


For å starte et prosjekt er app-abonnementet standardkonfigurasjonen, som følger:



KafkaMessageListenerContainer arver abstraktklassen AbstractMessageListenerContainer, og createSimpleLoggingConsumerRebalanceListener-metoden gir ut brukerens gruppeid og emne, partisjon.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partitions assigned: [defaultTopic-0]
Sett dynamisk topic og groupid, og prosjektstart-kommandoen er som følger:



Emnet settes til a1 og gruppeid er itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: tildelte partisjoner: [a1-0]
Spring overstyrer standardkonfigurasjonen inne i jar-pakken
https://www.itsvse.com/thread-10129-1-1.html

(Slutt)





Foregående:Trege forespørsler for MySQL-ytelsesoptimalisering
Neste:Spring Boot Kafka starter på nytt for å forkaste gamle data

Relaterte innlegg
Ansvarsfraskrivelse:
All programvare, programmeringsmateriell eller artikler publisert av Code Farmer Network er kun for lærings- og forskningsformål; Innholdet ovenfor skal ikke brukes til kommersielle eller ulovlige formål, ellers skal brukerne bære alle konsekvenser. Informasjonen på dette nettstedet kommer fra Internett, og opphavsrettstvister har ingenting med dette nettstedet å gjøre. Du må fullstendig slette innholdet ovenfor fra datamaskinen din innen 24 timer etter nedlasting. Hvis du liker programmet, vennligst støtt ekte programvare, kjøp registrering, og få bedre ekte tjenester. Hvis det foreligger noen krenkelse, vennligst kontakt oss på e-post.
Mail To:help@itsvse.com