Tak som sa stretávajú zaujímavé situácie:
V mojom integrácie test som odosielanie údajov na 2 témy, a mali by byť spotrebované žiadosť objednávky. Na prvý - userTopic, potom shoud byť konzumované userOrderTopic.
Keď som poslať moje správy v teste, odošle veľmi rýchlo, v rovnakom čase. Ale niekedy, aby konzumácia tým, že aplikácia je odlišná. (userOrder témy, a potom userTopic), čo prestávky môj test na všetkých.
Našiel som nejaké triks, ako by som mohol vyhnúť - niť spánku, atď. Ale verím, že je to zlé riešenie.
Som nový s kafka, ako výsledok s KafkaTestUtils. Existuje nejaký spôsob, ktorý by mohol zistiť, že správy v téme bola spotrebovaná/check kým správu, že bol spotrebovaný?
Niečo ako toto:
//check that message in userTopic was consumed, to have a chance send message to userOrderTopic
KafkaTestUtils.waitUntilBeConsumed(serverBootstrap, "user-consumer", topic, 0, messageToUserTopic)
alebo
KafkaTestUtils.getNowConsumedMessage(serverBootstrap, "user-consumer", topic, 0)
P. S. v mojom intergration test nemám accsess výrobcov/spotrebiteľa.
Alebo možno na jar.kafka /jar.kafka.skúšky sú ďalšie nástroje na to v správnej ceste?