MINOR: Remove unneeded FIXME
A previous iteration of the Raft patch had a broken check for disconnects. We had fixed the problem, but forgotten to remove the FIXME.
Reviewers: Ismael Juma
@@ -130,8 +130,6 @@ class KafkaNetworkChannel(time: Time,
val request = pendingOutbound.peek()
endpoints.get(request.destinationId) match {
case Some(node) =>
- // FIXME: This check is broken
-
if (client.connectionFailed(node)) {
pendingOutbound.poll()
val apiKey = ApiKeys.forId(request.data.apiKey)
