From c058f0fbea1d79db74773bb06bf55e7525e45644 Mon Sep 17 00:00:00 2001 From: adamw Date: Wed, 23 Aug 2023 13:29:52 +0200 Subject: [PATCH] Try different test approach --- kafka/src/test/scala/ox/kafka/KafkaTest.scala | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/kafka/src/test/scala/ox/kafka/KafkaTest.scala b/kafka/src/test/scala/ox/kafka/KafkaTest.scala index 7cf54202..f96713c1 100644 --- a/kafka/src/test/scala/ox/kafka/KafkaTest.scala +++ b/kafka/src/test/scala/ox/kafka/KafkaTest.scala @@ -64,7 +64,10 @@ class KafkaTest extends AnyFlatSpec with Matchers with EmbeddedKafka with Before // then given Deserializer[String] = new StringDeserializer() - consumeNumberMessagesFrom[String](topic, 3, timeout = 30.seconds) shouldBe List("a", "b", "c") + consumeFirstStringMessageFrom(topic) shouldBe "a" + consumeFirstStringMessageFrom(topic) shouldBe "b" + consumeFirstStringMessageFrom(topic) shouldBe "c" +// TODO consumeNumberMessagesFrom[String](topic, 3, timeout = 30.seconds) shouldBe List("a", "b", "c") } it should "commit offsets of processed messages" in {