Skip to content

Commit

Permalink
Trying to fix the test on slow machines
Browse files Browse the repository at this point in the history
  • Loading branch information
erikvanoosten committed Oct 30, 2023
1 parent 054052f commit 6c56770
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -857,7 +857,7 @@ object ConsumerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
_ <- fib2.join
_ <- ZIO.logDebug("Consumer 2 done")
// Give consumer 1 some time to consume the rest
_ <- ZIO.sleep(500.millis)
_ <- ZIO.sleep(1.second)
_ <- fib.join
_ <- ZIO.logDebug("Consumer 1 done")
// fib2 terminates after 20 messages, fib terminates after fib2 because of the rebalancing (drainCount==2)
Expand Down

0 comments on commit 6c56770

Please sign in to comment.