From ce0350c1579551f5ce907b0139b6647a8206d498 Mon Sep 17 00:00:00 2001 From: David Jacot Date: Tue, 7 Apr 2020 09:29:28 +0200 Subject: [PATCH] KAFKA-7965 (part-1): Fix one case which makes ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup flaky --- .../test/scala/integration/kafka/api/ConsumerBounceTest.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala b/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala index 24942fa300214..01bb4fe6c12c8 100644 --- a/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala +++ b/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala @@ -58,6 +58,7 @@ class ConsumerBounceTest extends AbstractConsumerTest with Logging { properties.put(KafkaConfig.GroupMaxSizeProp, maxGroupSize) properties.put(KafkaConfig.UncleanLeaderElectionEnableProp, "true") properties.put(KafkaConfig.AutoCreateTopicsEnableProp, "false") + properties.put(KafkaConfig.AutoLeaderRebalanceEnableProp, "false") FixedPortTestUtils.createBrokerConfigs(brokerCount, zkConnect, enableControlledShutdown = false) .map(KafkaConfig.fromProps(_, properties))