[kafka] branch trunk updated: KAFKA-14600: Reduce flakiness in ProducerIdExpirationTest (#13087)

[vi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

viktor pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 1c9d7c2398f KAFKA-14600: Reduce flakiness in ProducerIdExpirationTest (#13087)
1c9d7c2398f is described below

commit 1c9d7c2398faca867b7dfa88c13f8fa2dcf014dd
Author: Greg Harris <gr...@aiven.io>
AuthorDate: Tue Jan 10 02:48:31 2023 -0800

    KAFKA-14600: Reduce flakiness in ProducerIdExpirationTest (#13087)
    
    The broker appears to be timing out the producer ID before the test can see it.
    Increase the timeouts to compensate for slower CI environments.
    
    Signed-off-by: Greg Harris <gr...@aiven.io>
---
 .../test/scala/integration/kafka/api/ProducerIdExpirationTest.scala   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/core/src/test/scala/integration/kafka/api/ProducerIdExpirationTest.scala b/core/src/test/scala/integration/kafka/api/ProducerIdExpirationTest.scala
index 755b5ca2d26..194be302f3c 100644
--- a/core/src/test/scala/integration/kafka/api/ProducerIdExpirationTest.scala
+++ b/core/src/test/scala/integration/kafka/api/ProducerIdExpirationTest.scala
@@ -232,9 +232,9 @@ class ProducerIdExpirationTest extends KafkaServerTestHarness {
     serverProps.put(KafkaConfig.AutoLeaderRebalanceEnableProp, false.toString)
     serverProps.put(KafkaConfig.GroupInitialRebalanceDelayMsProp, "0")
     serverProps.put(KafkaConfig.TransactionsAbortTimedOutTransactionCleanupIntervalMsProp, "200")
-    serverProps.put(KafkaConfig.TransactionalIdExpirationMsProp, "500")
+    serverProps.put(KafkaConfig.TransactionalIdExpirationMsProp, "5000")
     serverProps.put(KafkaConfig.TransactionsRemoveExpiredTransactionalIdCleanupIntervalMsProp, "500")
-    serverProps.put(KafkaConfig.ProducerIdExpirationMsProp, "2000")
+    serverProps.put(KafkaConfig.ProducerIdExpirationMsProp, "10000")
     serverProps.put(KafkaConfig.ProducerIdExpirationCheckIntervalMsProp, "500")
     serverProps
   }