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

KAFKA-8091; Use commitSync to check connection failure in listener update test (#6450)

The use of consumer.poll() made the test flaky since in some cases, it doesn't wait for coordinator connection.

Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
parent 853f24a4
No related branches found
No related tags found
No related merge requests found
......@@ -1315,7 +1315,7 @@ class DynamicBrokerReconfigurationTest extends ZooKeeperTestHarness with SaslSet
executors += executor
val future = executor.submit(new Runnable() {
def run() {
assertEquals(0, consumer.poll(100).count)
consumer.commitSync()
}
})
verifyTimeout(future)
......
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