Try different test approach

softwaremill · Aug 23, 2023 · c058f0f · c058f0f
1 parent 4dec881
commit c058f0f
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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 {