This is an automated email from the ASF dual-hosted git repository. junrao pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 4110ad5208621a4bc0d184e95c909662b2819204 Author: Jun Rao <jun...@gmail.com> AuthorDate: Thu Mar 1 18:02:07 2018 -0800 Revert "Fixes requested by reviewer" This reverts commit ae51a15026e0dc10ef2df4bcafc85807dc8b4eb6. --- core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala b/core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala index 5cbb76e..28dbb73 100644 --- a/core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala +++ b/core/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala @@ -19,6 +19,7 @@ package kafka.zk import java.util.{Collections, Properties, UUID} import java.nio.charset.StandardCharsets.UTF_8 import java.util.concurrent.{CountDownLatch, TimeUnit} +import javax.security.auth.login.Configuration import kafka.api.{ApiVersion, LeaderAndIsr} import kafka.cluster.{Broker, EndPoint} @@ -56,7 +57,7 @@ class KafkaZkClientTest extends ZooKeeperTestHarness { val topicPartition20 = new TopicPartition(topic2, 0) val topicPartitions10_11 = Seq(topicPartition10, topicPartition11) - var otherZkClient: KafkaZkClient = _ + var otherZkClient: KafkaZkClient = null @Before override def setUp() { -- To stop receiving notification emails like this one, please contact jun...@apache.org.