Šis straipsnis yra veidrodinis mašininio vertimo straipsnis, spauskite čia norėdami pereiti prie originalaus straipsnio.

Architect_Programmer_Code žemės ūkio tinklas»Architektas › Programavimo › Java › Spring Boot dinamiškai nustato Kafkos temą arba GroupId
Rodinys: 21474|Atsakyti: 0

[Šaltinis] Spring Boot dinamiškai nustato Kafkos temą arba GroupId

[Kopijuoti nuorodą]
Paskelbta 2021-11-14 20:03:45 | | | |
Diegdami mikropaslaugas klasteryje, jei norime išduoti komandas visoms programoms, galime užsiprenumeruoti programas Kafkos temoms, tačiau reikia pažymėti, kad tą pačią temą turi gauti visos programos.

Naudokite "Docker", kad sukurtumėte "Kafka" programą su šiomis komandomis:

Pastaba: pakeiskite 192.168.1.166 tikruoju IP adresu

pom.xml Pristatykite pavasario-kafkos paketą taip:


Norėdami tinkinti Kafka vartotojo konfigūraciją, sukurkite naują KafkaConsumer failą taip:


Sukurkite naują vartotoją ConfigConsumer, kurio numatytoji konfigūracija: topic:defaultTopic,groupid:defaultGroupId, o kodas yra toks:

application.properties, kad sukonfigūruotumėte Kafkos adresą:


Norint pradėti projektą, programos prenumerata yra numatytoji konfigūracija, kaip nurodyta toliau.



KafkaMessageListenerContainer paveldi abstrakčią klasę AbstractMessageListenerContainer, o metodas createSimpleLoggingConsumerRebalanceListener išveda vartotojo groupid ir temos skaidinį.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: skaidiniai priskirti: [defaultTopic-0]
Dinamiškai nustatykite temą ir groupid, o projekto pradžios komanda yra tokia:



Tema nustatyta kaip a1, o grupės ID itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: pertvaros priskirtos: [a1-0]
"Spring" nepaiso numatytosios konfigūracijos stiklainio pakuotėje
https://www.itsvse.com/thread-10129-1-1.html

(Pabaiga)





Ankstesnis:Lėtos MySQL našumo optimizavimo užklausos
Kitą:"Spring Boot Kafka" paleidžiama iš naujo, kad atmestų senus duomenis

Susijusios žinutės
Atsakomybės apribojimas:
Visa programinė įranga, programavimo medžiaga ar straipsniai, kuriuos skelbia Code Farmer Network, yra skirti tik mokymosi ir mokslinių tyrimų tikslams; Aukščiau nurodytas turinys negali būti naudojamas komerciniais ar neteisėtais tikslais, priešingu atveju vartotojai prisiima visas pasekmes. Šioje svetainėje pateikiama informacija gaunama iš interneto, o ginčai dėl autorių teisių neturi nieko bendra su šia svetaine. Turite visiškai ištrinti aukščiau pateiktą turinį iš savo kompiuterio per 24 valandas nuo atsisiuntimo. Jei jums patinka programa, palaikykite autentišką programinę įrangą, įsigykite registraciją ir gaukite geresnes autentiškas paslaugas. Jei yra kokių nors pažeidimų, susisiekite su mumis el. paštu.
Mail To:help@itsvse.com