Šis raksts ir mašīntulkošanas spoguļraksts, lūdzu, noklikšķiniet šeit, lai pārietu uz oriģinālo rakstu.

Architect_Programmer_Code Lauksaimniecības tīkls»Arhitekts › Programmēšanas › Java › Spring Boot dinamiski iestata Kafkas tēmu vai grupas ID
Skats: 21474|Atbildi: 0

[Avots] Spring Boot dinamiski iestata Kafkas tēmu vai grupas ID

[Kopēt saiti]
Publicēts 14.11.2021 20:03:45 | | | |
Izvietojot mikropakalpojumus klasterī, ja mēs vēlamies izdot komandas visām lietojumprogrammām, mēs varam abonēt lietojumprogrammas Kafka tēmām, bet jāatzīmē, ka vienai un tai pašai tēmai ir jāiestata dažādi groupID, lai to saņemtu visas lietojumprogrammas.

Izmantojiet docker, lai izveidotu Kafka lietojumprogrammu ar šādām komandām:

Piezīme: Aizstājiet 192.168.1.166 ar savu faktisko IP adresi

pom.xml Iepazīstiniet pavasara kafkas paketi šādi:


Lai pielāgotu Kafka patērētāja konfigurāciju, izveidojiet jaunu KafkaConsumer failu šādi:


Izveidojiet jaunu patērētāju ConfigConsumer, kuram ir noklusējuma konfigurācija: topic:defaultTopic,groupid:defaultGroupId, un kods ir šāds:

application.properties, lai konfigurētu Kafkas adresi:


Lai sāktu projektu, programmas abonements ir noklusējuma konfigurācija, kā norādīts tālāk.



KafkaMessageListenerContainer pārmanto abstraktu klasi AbstractMessageListenerContainer, un metode createSimpleLoggingConsumerRebalanceListener izvada patērētāja grupas ID un tēmas nodalījumu.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: nodalījumi piešķirti: [defaultTopic-0]
Dinamiski iestatiet tēmu un grupas ID, un projekta sākuma komanda ir šāda:



Tēma ir iestatīta uz a1, un grupas ID ir itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: nodalījumi piešķirti: [a1-0]
Pavasaris ignorē noklusējuma konfigurāciju burkas iepakojumā
https://www.itsvse.com/thread-10129-1-1.html

(Beigas)





Iepriekšējo:Lēni vaicājumi MySQL veiktspējas optimizācijai
Nākamo:Pavasara sāknēšana Kafka atsākas, lai atmest vecos datus

Saistītās ziņas
Atruna:
Visa programmatūra, programmēšanas materiāli vai raksti, ko publicē Code Farmer Network, ir paredzēti tikai mācību un pētniecības mērķiem; Iepriekš minēto saturu nedrīkst izmantot komerciāliem vai nelikumīgiem mērķiem, pretējā gadījumā lietotājiem ir jāuzņemas visas sekas. Informācija šajā vietnē nāk no interneta, un autortiesību strīdiem nav nekāda sakara ar šo vietni. Iepriekš minētais saturs ir pilnībā jāizdzēš no datora 24 stundu laikā pēc lejupielādes. Ja jums patīk programma, lūdzu, atbalstiet oriģinālu programmatūru, iegādājieties reģistrāciju un iegūstiet labākus oriģinālus pakalpojumus. Ja ir kādi pārkāpumi, lūdzu, sazinieties ar mums pa e-pastu.
Mail To:help@itsvse.com