This is an automated email from the ASF dual-hosted git repository. mimaison pushed a commit to branch 3.2 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 2e229db62d0dd31b19cc8139824b4481b52ea7d8 Author: Divij Vaidya <di...@amazon.com> AuthorDate: Tue Aug 2 19:48:25 2022 +0200 KAFKA-14122: Fix flaky test DynamicBrokerReconfigurationTest#testKeyStoreAlter (#12452) Reviewers: Mickael Maison <mickael.mai...@gmail.com> --- .../integration/kafka/server/DynamicBrokerReconfigurationTest.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala b/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala index a76fa913817..2884016ee5c 100644 --- a/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala +++ b/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala @@ -377,7 +377,9 @@ class DynamicBrokerReconfigurationTest extends QuorumTestHarness with SaslSetup // Produce/consume should work with new truststore with new producer/consumer val producer = ProducerBuilder().trustStoreProps(sslProperties2).maxRetries(0).build() - val consumer = ConsumerBuilder("group1").trustStoreProps(sslProperties2).topic(topic2).build() + // Start the new consumer in a separate group than the continous consumer started at the beginning of the test so + // that it is not disrupted by rebalance. + val consumer = ConsumerBuilder("group2").trustStoreProps(sslProperties2).topic(topic2).build() verifyProduceConsume(producer, consumer, 10, topic2) // Broker keystore update for internal listener with incompatible keystore should fail without update