Acest articol este un articol oglindă al traducerii automate, vă rugăm să faceți clic aici pentru a sări la articolul original.

Architect_Programmer_Code Rețeaua Agricolă»Arhitect › Programare › Java › Spring Boot setează dinamic Topic sau GroupId-ul lui Kafka
Vedere: 21474|Răspunde: 0

[Sursă] Spring Boot setează dinamic Topic sau GroupId-ul lui Kafka

[Copiază linkul]
Postat pe 14.11.2021 20:03:45 | | | |
Când implementăm microservicii într-un cluster, dacă dorim să emitem comenzi către toate aplicațiile, putem abona aplicațiile la subiecte Kafka, dar trebuie menționat că trebuie setate grupID-uri diferite pentru ca același subiect să fie primit de toate aplicațiile.

Folosește docker pentru a construi o aplicație Kafka cu următoarele comenzi:

Notă: Înlocuiește 192.168.1.166 cu adresa ta IP reală

pom.xml Introduceți pachetul spring-kafka astfel:


Pentru a personaliza configurația Kafka Consumer, creați un nou fișier KafkaConsumer după cum urmează:


Creează un nou ConfigurConsumator pentru consumatori, care are configurația implicită: topic:defaultTopic,groupid:defaultGroupId, iar codul este următorul:

application.properties pentru a configura adresa lui Kafka:


Pentru a începe un proiect, abonamentul la aplicație este configurația implicită, după cum urmează:



KafkaMessageListenerContainer moștenește clasa abstractă AbstractMessageListenerContainer, iar metoda createSimpleLoggingConsumerRebalanceListener generează partiția groupid și topic a consumatorului.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partiții atribuite: [defaultTopic-0]
Setează dinamic subiectul și grupidul, iar comanda de start a proiectului este următoarea:



Tema este setată pe a1, iar grupidul este itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partiții atribuite: [a1-0]
Spring suprascrie configurația implicită din interiorul pachetului jar
https://www.itsvse.com/thread-10129-1-1.html

(Sfârșit)





Precedent:Interogări lente pentru optimizarea performanței MySQL
Următor:Spring Boot Kafka repornește pentru a elimina datele vechi

Postări conexe
Disclaimer:
Tot software-ul, materialele de programare sau articolele publicate de Code Farmer Network sunt destinate exclusiv scopurilor de învățare și cercetare; Conținutul de mai sus nu va fi folosit în scopuri comerciale sau ilegale, altfel utilizatorii vor suporta toate consecințele. Informațiile de pe acest site provin de pe Internet, iar disputele privind drepturile de autor nu au legătură cu acest site. Trebuie să ștergi complet conținutul de mai sus de pe calculatorul tău în termen de 24 de ore de la descărcare. Dacă îți place programul, te rugăm să susții software-ul autentic, să cumperi înregistrarea și să primești servicii autentice mai bune. Dacă există vreo încălcare, vă rugăm să ne contactați prin e-mail.
Mail To:help@itsvse.com