You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by js...@apache.org on 2022/09/01 00:03:53 UTC
[kafka] branch 3.3 updated: KAFKA-14122: Fix flaky test DynamicBrokerReconfigurationTest#testKeyStoreAlter (#12452)
This is an automated email from the ASF dual-hosted git repository.
jsancio pushed a commit to branch 3.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.3 by this push:
new b7e9fc88ad KAFKA-14122: Fix flaky test DynamicBrokerReconfigurationTest#testKeyStoreAlter (#12452)
b7e9fc88ad is described below
commit b7e9fc88ad057a595f069dd399ce1ec376802817
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 <mi...@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 bd6308c0b8..295ad06121 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