Skip to content
Snippets Groups Projects
Unverified Commit d436f32e authored by Rajini Sivaram's avatar Rajini Sivaram Committed by GitHub
Browse files

KAFKA-8091; Remove unsafe produce from dynamic listener update test (#6443)

Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
parent a648ef0b
No related branches found
No related tags found
No related merge requests found
......@@ -935,8 +935,6 @@ class DynamicBrokerReconfigurationTest extends ZooKeeperTestHarness with SaslSet
.autoOffsetReset("latest")
.build()
verifyProduceConsume(producer1, consumer1, numRecords = 10, topic)
// send another message to check consumer later
producer1.send(new ProducerRecord(topic, "key", "value")).get(1, TimeUnit.SECONDS)
val config = servers.head.config
val existingListenerCount = config.listeners.size
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment