Questo articolo è un articolo speculare di traduzione automatica, clicca qui per saltare all'articolo originale.

Architect_Programmer_Code Rete Agricola»Architetto › Programmazione › Giava › Spring Boot imposta dinamicamente il Topic o GroupId di Kafka
Vista: 21474|Risposta: 0

[Fonte] Spring Boot imposta dinamicamente il Topic o GroupId di Kafka

[Copiato link]
Pubblicato su 14/11/2021 20:03:45 | | | |
Quando si distribuiscono microservizi in un cluster, se vogliamo emettere comandi a tutte le applicazioni, possiamo sottoscrivere le applicazioni a argomenti Kafka, ma va notato che è necessario impostare diversi GroupID affinché lo stesso argomento venga ricevuto da tutte le applicazioni.

Usa docker per costruire un'applicazione Kafka con i seguenti comandi:

Nota: Sostituisci 192.168.1.166 con il tuo vero indirizzo IP

pom.xml Introdurre il pacchetto spring-kafka come segue:


Per personalizzare la configurazione Kafka consumer, crea un nuovo file KafkaConsumer come segue:


Crea un nuovo ConfigurConsumer per consumatori, che ha la configurazione predefinita: topic:defaultTopic,groupid:defaultGroupId, e il codice è il seguente:

application.properties per configurare l'indirizzo di Kafka:


Per avviare un progetto, l'abbonamento all'app è la configurazione predefinita, come segue:



KafkaMessageListenerContainer eredita la classe astratta AbstractMessageListenerContainer, e il metodo createSimpleLoggingConsumerRebalanceListener produce il groupid e la partizione del topic del consumatore.

2021-11-14 19:44:26.689 INFO 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partizioni assegnate: [defaultTopic-0]
Imposta dinamicamente l'argomento e il groupid, e il comando di inizio progetto è il seguente:



L'argomento è impostato su a1 e il groupid è itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: partizioni assegnate: [a1-0]
Spring sovrascrive la configurazione predefinita all'interno del package jar
https://www.itsvse.com/thread-10129-1-1.html

(Fine)





Precedente:Query lente per l'ottimizzazione delle prestazioni MySQL
Prossimo:Spring Boot Kafka riavvia per scartare i dati vecchi

Post correlati
Disconoscimento:
Tutto il software, i materiali di programmazione o gli articoli pubblicati dalla Code Farmer Network sono destinati esclusivamente all'apprendimento e alla ricerca; I contenuti sopra elencati non devono essere utilizzati per scopi commerciali o illegali, altrimenti gli utenti dovranno sostenere tutte le conseguenze. Le informazioni su questo sito provengono da Internet, e le controversie sul copyright non hanno nulla a che fare con questo sito. Devi eliminare completamente i contenuti sopra elencati dal tuo computer entro 24 ore dal download. Se ti piace il programma, ti preghiamo di supportare software autentico, acquistare la registrazione e ottenere servizi autentici migliori. In caso di violazione, vi preghiamo di contattarci via email.
Mail To:help@itsvse.com