From 4eadaff6b2a9c730b7108f4386985714a4a3aea9 Mon Sep 17 00:00:00 2001 From: Lee Dongjin Date: Tue, 7 May 2019 16:36:59 +0100 Subject: [PATCH] MINOR: Remove unused field in `ListenerConnectionQuota` Reviewers: Jason Gustafson --- core/src/main/scala/kafka/network/SocketServer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala index 1f4f1b69244..619d2605ac9 100644 --- a/core/src/main/scala/kafka/network/SocketServer.scala +++ b/core/src/main/scala/kafka/network/SocketServer.scala @@ -1228,7 +1228,7 @@ class ConnectionQuotas(config: KafkaConfig, time: Time) extends Logging { class ListenerConnectionQuota(lock: Object, listener: ListenerName) extends ListenerReconfigurable { @volatile private var _maxConnections = Int.MaxValue - private val listenerPropName = s"${listener.configPrefix}${KafkaConfig.MaxConnectionsProp}" + def maxConnections: Int = _maxConnections override def listenerName(): ListenerName = listener