Cet article est un article miroir de traduction automatique, veuillez cliquer ici pour accéder à l’article original.

Architect_Programmer_Code Réseau agricole»Architecte › Programmation › Java › Spring Boot définit dynamiquement le Topic ou GroupId de Kafka
Vue: 21474|Répondre: 0

[Source] Spring Boot définit dynamiquement le Topic ou GroupId de Kafka

[Copié le lien]
Publié sur 14/11/2021 20:03:45 | | | |
Lors du déploiement de microservices dans un cluster, si nous voulons émettre des commandes à toutes les applications, nous pouvons souscrire les applications aux sujets Kafka, mais il convient de noter que différents groupIDs doivent être définis pour que le même sujet soit reçu par toutes les applications.

Utilisez docker pour construire une application Kafka avec les commandes suivantes :

Note : Remplacez 192.168.1.166 par votre adresse IP réelle

pom.xml Introduisez le package spring-kafka comme suit :


Pour personnaliser la configuration Kafka Consumer, créez un nouveau fichier KafkaConsumer comme suit :


Créez un nouveau ConfigConsumer grand public, qui a la configuration par défaut : topic :defaultTopic,groupid :defaultGroupId, et le code est le suivant :

application.properties pour configurer l’adresse de Kafka :


Pour démarrer un projet, l’abonnement à l’application est la configuration par défaut, comme suit :



KafkaMessageListenerContainer hérite de la classe abstraite AbstractMessageListenerContainer, et la méthode createSimpleLoggingConsumerRebalanceListener produit le groupid et la partition du sujet du consommateur.

2021-11-14 19:44:26.689 INFOS 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId : partitions assignées : [defaultTopic-0]
Définissez dynamiquement le topic et groupid, et la commande début du projet est la suivante :



Le sujet est réglé sur a1 et le groupid est itsvse.com

2021-11-14 19:46:25.330 INFO 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com : partitions assignées : [a1-0]
Le ressort supprime la configuration par défaut à l’intérieur du boîtier jar
https://www.itsvse.com/thread-10129-1-1.html

(Fin)





Précédent:Requêtes lentes pour l’optimisation des performances MySQL
Prochain:Spring Boot Kafka redémarre pour défaire les anciennes données

Articles connexes
Démenti:
Tous les logiciels, supports de programmation ou articles publiés par Code Farmer Network sont uniquement destinés à l’apprentissage et à la recherche ; Le contenu ci-dessus ne doit pas être utilisé à des fins commerciales ou illégales, sinon les utilisateurs assumeront toutes les conséquences. Les informations sur ce site proviennent d’Internet, et les litiges de droits d’auteur n’ont rien à voir avec ce site. Vous devez supprimer complètement le contenu ci-dessus de votre ordinateur dans les 24 heures suivant le téléchargement. Si vous aimez le programme, merci de soutenir un logiciel authentique, d’acheter l’immatriculation et d’obtenir de meilleurs services authentiques. En cas d’infraction, veuillez nous contacter par e-mail.
Mail To:help@itsvse.com