From a57281ab5ea39a09ff836df6bba9862cfe3adbef Mon Sep 17 00:00:00 2001 From: Rajini Sivaram Date: Thu, 14 Mar 2019 09:33:34 +0000 Subject: [PATCH] KAFKA-8091; Remove unsafe produce from dynamic listener update test --- .../kafka/server/DynamicBrokerReconfigurationTest.scala | 2 -- 1 file changed, 2 deletions(-) diff --git a/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala b/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala index c28fcea15cb38..d1427b2356c42 100644 --- a/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala +++ b/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala @@ -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