Ta članek je zrcalni članek strojnega prevajanja, kliknite tukaj za skok na izvirni članek.

Architect_Programmer_Code Kmetijska mreža»Arhitekt › Programiranje › Java › Spring Boot dinamično nastavi Topic ali GroupId Kafke
Pogled: 21474|Odgovoriti: 0

[Vir] Spring Boot dinamično nastavi Topic ali GroupId Kafke

[Kopiraj povezavo]
Objavljeno na 14. 11. 2021 20:03:45 | | | |
Pri nameščanju mikroservisov v gruči, če želimo izdajati ukaze vsem aplikacijam, lahko aplikacije naročimo na Kafka teme, vendar je treba opozoriti, da je treba za isto temo nastaviti različne groupID-je, da jih prejmejo vse aplikacije.

Uporabite docker za izdelavo Kafka aplikacije z naslednjimi ukazi:

Opomba: Zamenjajte 192.168.1.166 z vašim dejanskim IP naslovom

pom.xml Predstavite paket spring-kafka na naslednji način:


Za prilagoditev Kafka potrošniške konfiguracije ustvarite novo datoteko KafkaConsumer na naslednji način:


Ustvarite novega potrošniškega ConfigConsumer, ki ima privzeto konfiguracijo: topic:defaultTopic,groupid:defaultGroupId, koda pa je naslednja:

application.properties za konfiguracijo naslova Kafka:


Za začetek projekta je naročnina aplikacije privzeta konfiguracija, kot sledi:



KafkaMessageListenerContainer podeduje abstraktni razred AbstractMessageListenerContainer, metoda createSimpleLoggingConsumerRebalanceListener pa izpiše uporabnikov groupid in temo, particijo.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: dodeljene particije: [defaultTopic-0]
Dinamično nastavite temo in groupid, ukaz project start pa je naslednji:



Tema je nastavljena na a1, groupid pa je itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: dodeljene particije: [a1-0]
Vzmet preglasi privzeto konfiguracijo znotraj paketa jar
https://www.itsvse.com/thread-10129-1-1.html

(Konec)





Prejšnji:Počasne poizvedbe za optimizacijo zmogljivosti MySQL
Naslednji:Spring Boot Kafka se ponovno zažene, da zavrže stare podatke

Sorodne objave
Disclaimer:
Vsa programska oprema, programski materiali ali članki, ki jih izdaja Code Farmer Network, so namenjeni zgolj učnim in raziskovalnim namenom; Zgornja vsebina ne sme biti uporabljena v komercialne ali nezakonite namene, sicer uporabniki nosijo vse posledice. Informacije na tej strani prihajajo z interneta, spori glede avtorskih pravic pa nimajo nobene zveze s to stranjo. Zgornjo vsebino morate popolnoma izbrisati z računalnika v 24 urah po prenosu. Če vam je program všeč, podprite pristno programsko opremo, kupite registracijo in pridobite boljše pristne storitve. Če pride do kakršne koli kršitve, nas prosimo kontaktirajte po elektronski pošti.
Mail To:help@itsvse.com