Tämä artikkeli on konekäännöksen peiliartikkeli, klikkaa tästä siirtyäksesi alkuperäiseen artikkeliin.

Architect_Programmer_Code Maatalousverkosto»Arkkitehti › Ohjelmointi › Jaava › Spring Boot asettaa dynaamisesti Kafkan aiheen tai GroupId:n
Näkymä: 21474|Vastaus: 0

[Lähde] Spring Boot asettaa dynaamisesti Kafkan aiheen tai GroupId:n

[Kopioi linkki]
Julkaistu 14.11.2021 20.03.45 | | | |
Kun otamme mikropalveluita käyttöön klusterissa, jos haluamme antaa käskyjä kaikille sovelluksille, voimme tilata sovellukset Kafka-aiheisiin, mutta on huomattava, että eri ryhmätunnukset täytyy asettaa, jotta sama aihe vastaanotetaan kaikille sovelluksille.

Käytä dockeria rakentaaksesi Kafka-sovelluksen seuraavilla komennoilla:

Huomautus: Korvaa 192.168.1.166 todellisella IP-osoitteellasi

pom.xml Esitellään jousi-kafka-paketti seuraavasti:


Kafka-kuluttajakonfiguraation muokkaamiseksi luo uusi KafkaConsumer-tiedosto seuraavasti:


Luo uusi kuluttajalle ConfigConsumer, jonka oletusasetukset ovat topic:defaultTopic, groupid:defaultGroupId, ja koodi on seuraava:

application.properties määrittääkseen Kafkan osoitteen:


Projektin aloittamiseksi sovelluksen tilaus on oletusasetuksena seuraavasti:



KafkaMessageListenerContainer perii AbstractMessageListenerContainer -abstraktin luokan, ja createSimpleLoggingConsumerRebalanceListener -metodi tuottaa kuluttajan groupid- ja topic-osion.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: osiot määritetty: [defaultTopic-0]
Aseta aihe ja ryhmätunnus dynaamisesti, ja projektin aloituskomento on seuraava:



Aihe on asetettu a1:een ja groupid on itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: osiot määritetty: [a1-0]
Spring ohittaa jar-paketin oletusasetukset
https://www.itsvse.com/thread-10129-1-1.html

(Loppu)





Edellinen:Hitaat kyselyt MySQL:n suorituskyvyn optimoinnissa
Seuraava:Spring Boot Kafka käynnistyy uudelleen vanhojen tietojen poistamiseksi

Aiheeseen liittyvät julkaisut
Vastuuvapauslauseke:
Kaikki Code Farmer Networkin julkaisemat ohjelmistot, ohjelmamateriaalit tai artikkelit ovat tarkoitettu vain oppimis- ja tutkimustarkoituksiin; Yllä mainittua sisältöä ei saa käyttää kaupallisiin tai laittomiin tarkoituksiin, muuten käyttäjät joutuvat kantamaan kaikki seuraukset. Tämän sivuston tiedot ovat peräisin internetistä, eikä tekijänoikeuskiistat liity tähän sivustoon. Sinun tulee poistaa yllä oleva sisältö kokonaan tietokoneeltasi 24 tunnin kuluessa lataamisesta. Jos pidät ohjelmasta, tue aitoa ohjelmistoa, osta rekisteröityminen ja hanki parempia aitoja palveluita. Jos rikkomuksia ilmenee, ota meihin yhteyttä sähköpostitse.
Mail To:help@itsvse.com