MINOR: Fix flaky ProducerIdManagerTest.testUnrecoverableErrors (apach…

…e#14688) We add a sleep until RetryBackoffMs to ensure that next call to generateProducerId() is triggered. Reviewers: Divij Vaidya <diviv@amazon.com>
confluentinc · Nov 22, 2023 · 71dd669 · 71dd669
1 parent 9990b61
commit 71dd669
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/test/scala/unit/kafka/coordinator/transaction/ProducerIdManagerTest.scala b/core/src/test/scala/unit/kafka/coordinator/transaction/ProducerIdManagerTest.scala
@@ -195,6 +195,7 @@ class ProducerIdManagerTest {
     verifyNewBlockAndProducerId(manager, new ProducerIdsBlock(0, 0, 1), 0)
 
     manager.error = error
+    time.sleep(RetryBackoffMs)
     verifyFailure(manager)
 
     manager.error = Errors.NONE