root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-14122: Fix flaky test DynamicBrokerReconfigurationTest#testKeyStoreAlter (#12452) 

Reviewers: Mickael Maison <mickael.maison@gmail.com>
This commit is contained in:
Divij Vaidya 2022-08-02 19:48:25 +02:00 committed by Mickael Maison
parent 44e419722e
commit 2e229db62d
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala
View File

@ -377,7 +377,9 @@ class DynamicBrokerReconfigurationTest extends QuorumTestHarness with SaslSetup
// Produce/consume should work with new truststore with new producer/consumer // Produce/consume should work with new truststore with new producer/consumer
val producer = ProducerBuilder().trustStoreProps(sslProperties2).maxRetries(0).build() 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) verifyProduceConsume(producer, consumer, 10, topic2)
// Broker keystore update for internal listener with incompatible keystore should fail without update // Broker keystore update for internal listener with incompatible keystore should fail without update