Donc, j'ai connu la situation intéressante:
Dans mon test d'intégration-je envoyer des données à 2 sujets, et ils doivent être consommés en application par le décret. Au premier userTopic, puis devraient être consommés userOrderTopic.
Lorsque j'envoie mes messages dans le test, il envoie vraiment rapidement, en même temps. Mais parfois, l'ordre de la consommation par application est différente. (userOrder sujet, puis userTopic) ce qui brise mon test à tous.
J'ai trouvé des triks, comment je pourrais l'éviter - fil de sommeil, etc. Mais je crois que c'est une mauvaise solution.
Je suis nouvelle de kafka, comme résultat avec KafkaTestUtils. Existe t'il une méthode, qui a pu vérifier que le message dans le sujet a été consommé/check jusqu'à ce que le message a été consommé?
Quelque chose comme ceci:
//check that message in userTopic was consumed, to have a chance send message to userOrderTopic
KafkaTestUtils.waitUntilBeConsumed(serverBootstrap, "user-consumer", topic, 0, messageToUserTopic)
ou
KafkaTestUtils.getNowConsumedMessage(serverBootstrap, "user-consumer", topic, 0)
P. S. mon insertion test je n'ai pas accsess de producteur/consommateur.
Ou peut-être au printemps.kafka /printemps.kafka.de test sont un autre des outils pour le faire de manière adéquate?