तो, मैं का सामना करना पड़ा दिलचस्प स्थिति:
में एकीकरण परीक्षण मैं डेटा भेजने के लिए 2 विषयों, और वे का सेवन किया जाना चाहिए द्वारा आवेदन के द्वारा आदेश. पहली बार में - userTopic, तो shoud भस्म हो 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. में एकीकरण परीक्षण मैं नहीं है accsess करने के लिए उत्पादक/उपभोक्ता.
या हो सकता है वसंत ऋतु में.काफ्का /वसंत । काफ्का.परीक्षण कर रहे हैं एक और उपकरण में यह करने के लिए उचित तरीका है?