See artikkel on masintõlke peegelartikkel, palun klõpsake siia, et hüpata algse artikli juurde.

Architect_Programmer_Code Põllumajandusvõrgustik»Arhitekt › Programmeerimine › Java › Spring Boot seab dünaamiliselt Kafka teema või GroupId
Vaade: 21474|Vastuse: 0

[Allikas] Spring Boot seab dünaamiliselt Kafka teema või GroupId

[Kopeeri link]
Postitatud 14.11.2021 20:03:45 | | | |
Mikroteenuste juurutamisel klastris, kui soovime anda käske kõigile rakendustele, saame rakendused tellida Kafka teemadele, kuid tuleb märkida, et sama teema vastuvõtmiseks kõigile rakendustele tuleb määrata erinevad grupi-ID-d.

Kasuta dockerit, et ehitada Kafka rakendus järgmiste käskudega:

Märkus: Asenda 192.168.1.166 oma tegeliku IP-aadressiga

pom.xml Tutvustage spring-kafka paketti järgmiselt:


Kafka tarbija konfiguratsiooni kohandamiseks loo uus KafkaConsumer fail järgmiselt:


Loo uus tarbija ConfigConsumer, mille vaikimisi konfiguratsioon: topic:defaultTopic,groupid:defaultGroupId ja kood on järgmine:

application.properties Kafka aadressi seadistamiseks:


Projekti alustamiseks on rakenduse tellimus vaikimisi seadistus, järgmiselt:



KafkaMessageListenerContainer pärib AbstractMessageListenerContainer abstraktklassi ning createSimpleLoggingConsumerRebalanceListener meetod väljastab tarbija grupid ja teema, partitsiooni.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partitions määratud: [defaultTopic-0]
Dünaamiliselt sea teema ja grupid ning projekti käivitamise käsk on järgmine:



Teema on seatud a1-le ja grupid itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partitsioonid määratud: [a1-0]
Spring tühistab vaikimisi konfiguratsiooni jar-paketis
https://www.itsvse.com/thread-10129-1-1.html

(Lõpp)





Eelmine:Aeglased päringud MySQL jõudluse optimeerimiseks
Järgmine:Spring Boot Kafka taaskäivitub, et vanu andmeid ära visata

Seotud postitused
Disclaimer:
Kõik Code Farmer Networki poolt avaldatud tarkvara, programmeerimismaterjalid või artiklid on mõeldud ainult õppimiseks ja uurimistööks; Ülaltoodud sisu ei tohi kasutada ärilistel ega ebaseaduslikel eesmärkidel, vastasel juhul kannavad kasutajad kõik tagajärjed. Selle saidi info pärineb internetist ning autoriõiguste vaidlused ei ole selle saidiga seotud. Ülaltoodud sisu tuleb oma arvutist täielikult kustutada 24 tunni jooksul pärast allalaadimist. Kui sulle programm meeldib, palun toeta originaaltarkvara, osta registreerimist ja saa paremaid ehtsaid teenuseid. Kui esineb rikkumist, palun võtke meiega ühendust e-posti teel.
Mail To:help@itsvse.com