Skip to content

Commit

Permalink
Fix Race in Test
Browse files Browse the repository at this point in the history
  • Loading branch information
garyrussell committed Oct 25, 2023
1 parent fbbe8f5 commit ad5e754
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -2744,8 +2744,8 @@ public void rePausePartitionAfterRebalance() throws Exception {
// hold up the consumer thread while we revoke/assign partitions on the test thread
suspendConsumerThread.await(10, TimeUnit.SECONDS);
}
Thread.sleep(50);
firstPoll.countDown();
Thread.sleep(50);
return ConsumerRecords.empty();
});
AtomicReference<ConsumerRebalanceListener> rebal = new AtomicReference<>();
Expand Down

0 comments on commit ad5e754

Please sign in to comment.