File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -9,5 +9,5 @@ import org.scalatest.wordspec.AsyncWordSpec
99import scala .concurrent .duration .*
1010
1111trait AsyncIntSpec extends AsyncWordSpec with AsyncIOSpec with Matchers with OptionValues with Eventually {
12- override implicit val patienceConfig : PatienceConfig = PatienceConfig (200 .millis, 10 .seconds )
12+ override implicit val patienceConfig : PatienceConfig = PatienceConfig (30 .seconds, 500 .millis )
1313}
Original file line number Diff line number Diff line change @@ -107,7 +107,10 @@ trait KafkaHelpers[F[_]] {
107107 for {
108108 records <- r
109109 messageKeys = records.map { case (k, _) => k }
110- } yield messageKeys should contain theSameElementsAs messageKeys
110+ } yield {
111+ messageKeys should not be empty
112+ messageKeys should contain theSameElementsAs messageKeys.toSet
113+ }
111114 }
112115
113116 def consumeEventually (
You can’t perform that action at this time.
0 commit comments