Skip to content

Commit

Permalink
KAFKA-14122: Fix flaky test DynamicBrokerReconfigurationTest#testKeyS…
Browse files Browse the repository at this point in the history
…toreAlter (#12452)


Reviewers: Mickael Maison <mickael.maison@gmail.com>
  • Loading branch information
divijvaidya authored and mimaison committed Aug 25, 2022
1 parent 44e4197 commit 2e229db
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 2e229db

Please # to comment.