Le consommateur Kafka n'a pas pu interroger

Question

Si une application grand public kafka lit un message de kafka, une autre n'a pas pu lire et vice-versa.

Nous exécutons deux applications indépendantes, l'une traitera le message et l'autre lira et placera dans une base de données.

message qui est été le traitement dans la première application n'est pas disponible dans la seconde application

Answer 1

Sans voir le code que je ne peux que deviner ... :-) Je pense que vous avez un sujet avec une seule partition et les deux applications grand public appartiennent au même groupe de consommateurs. Dans ce cas, un seul consommateur reçoit des messages de la seule partition du sujet. Si vous souhaitez que les deux applications reçoivent des messages du même sujet, vous devez les placer dans différents groupes de consommateurs (paramètre group.id pour les propriétés du consommateur).