Comment créer plus d'un groupe de consommateurs Kafka dans une application de démarrage à ressort

Question

Je souhaite créer plus d'un groupe de consommateurs Kafka dans une application de démarrage à ressort pour traiter différentes files d'attente Kafka différentes. Le scénario d'exigence est basé sur la criticité du message, il doit être poussé vers une autre file d'attente Kafka. Et pour gérer différentes files d'attente Kafka je veux créer un groupe de consommateurs Kafka dédié. Mais je ne suis pas sûr que je peux créer plus d'un groupe de consommateurs Kafka dans une application de démarrage de printemps ou non.

Actuellement, j'ai trois sujets kafka avec 4 partion par sujet et un seul groupe de consommateurs kafka avec trois consommateurs kafka. Ces trois consommateurs kafka lisant trois files d'attente kafka dédié.

J'ai fait une recherche Google mais je n'ai trouvé aucun indice à ce sujet.

Answer 1

Votre question n'est pas claire et vous semblez ne pas être familier avec Kafka. Tout d'abord cela appelé topic dans Kafka, pas la file d'attente. Et c'est le concept sujet parce que nous pouvons abonner différents groupes de consommateurs pour obtenir le même message - la sémantique de publication-abonné.

On ne sait pas trop pourquoi vous avez besoin de plusieurs groupes de consommateurs puisque même dans le même groupe, différents consommateurs peuvent consommer des sujets différents.

Quoi qu'il en soit, vous devriez envisager d'utiliser:

/** 
* Override the {@code group.id} property for the consumer factory with this value 
* for this listener only. 
* @return the group id. 
* @since 1.3 
*/ 
String groupId() default ""; 

Sur le @KafkaListener à vos besoins.