diff --git a/core/src/test/scala/integration/kafka/api/ProducerIdExpirationTest.scala b/core/src/test/scala/integration/kafka/api/ProducerIdExpirationTest.scala index 755b5ca2d268a..194be302f3ce9 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 }