root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

MINOR: Remove unused local variable in SocketServer (#4669) 

Reviewers: Ismael Juma <ismael@juma.me.uk>
This commit is contained in:
Jimin Hsieh 2018-03-09 23:44:57 +08:00 committed by Ismael Juma
parent 6a383d8bc4
commit db619c6da2
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/scala/kafka/network/SocketServer.scala
View File

@ -124,7 +124,7 @@ class SocketServer(val config: KafkaConfig, val metrics: Metrics, val time: Time
val securityProtocol = endpoint.securityProtocol
val listenerProcessors = new ArrayBuffer[Processor]()
for (i <- 0 until newProcessorsPerListener) {
for (_ <- 0 until newProcessorsPerListener) {
val processor = newProcessor(nextProcessorId, connectionQuotas, listenerName, securityProtocol, memoryPool)
listenerProcessors += processor
requestChannel.addProcessor(processor)