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))