因此，我面临着有趣的情况：
在我的一体化测试我送数据以2个主题，并应将它们消耗的应用程序的顺序。 在第一userTopic，则应该消耗userOrderTopic.
当我给我的消息测试，它发真的很迅速，在同一时间。 但有时，消耗通过应用程序是不同的。 (userOrder主题，然后userTopic)什么打破了我的测试。
我发现了一些triks，我怎么可能避免它纹睡眠等。 但我认为，这是不好的解决方案。
我的新卡夫卡，作为的结果与KafkaTestUtils. 是否有任何方法，该方法可以检查这条信息的话题是消耗/检查，直到这消息消耗了?
事情是这样的：
//check that message in userTopic was consumed, to have a chance send message to userOrderTopic
KafkaTestUtils.waitUntilBeConsumed(serverBootstrap, "user-consumer", topic, 0, messageToUserTopic)
或
KafkaTestUtils.getNowConsumedMessage(serverBootstrap, "user-consumer", topic, 0)
P.S.在我的一体化测试，我没有挑选商品，生产者/消费者。
或者也许在春天。卡夫卡/春天。卡夫卡.试验是另一个工具，做到在适当的方式？