แล้วฉันเผชิญหน้ากับสถานการณ์ที่น่าสนใจ:
ในของฉันร่วมทดสอบฉันส่งข้อมูลต้อง 2 หัวข้อคุและพวกเขาควรจะต้องกลือนกินโดยโปรแกรมโดยคำสั่ง ตอนแรก-userTopic แล้ว shoud ต้องกลือนกิน userOrderTopic.
ตอนที่ฉันส่งข้อความของผมในการทดสอบมันส่งจริงๆอย่างรวดเร็วในเวลาเดียวกัน แต่บางครั้งคำสั่งของกินโดยโปรแกรมต่างออกไป (userOrder เรื่องนั้ userTopic)สิ่งที่ทำให้ฉันทดสอบทั้งหมด
ฉันเจอบางอย่า triks ว่าฉันจะสามารถหลีกเลี่ยงมัน-ด้านหลับเป็นต้น แต่ฉันอยากจะเชื่อเลยว่ามันเลวคิดอะไรบางอย่างออก
ผมใหม่กับ kafka อย่างที่ผลลัพธ์ที่ได้ด้วย 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)
พีเอสในของฉัน intergration ทดสอบฉันไม่มี accsess เพื่อโปรดิวเซอร์/ของลูกค้า.
หรือบางทีอาจจะอยู่ในฤดูใบไม้ผลิแล้วkafka/ฤดูใบไม้ผลิแล้วkafka.ทดสอบพออีกเครื่องมือที่จะทำมันอยู่ในที่เหมาะสมทาง?