Repository: kafka Updated Branches: refs/heads/0.9.0 8c370093d -> 33809f5eb
MINOR: Remove `InvalidReceiveException` catch in `SocketServer` `Selector.poll` no longer throws it. Author: Ismael Juma <[email protected]> Reviewers: Jun Rao <[email protected]> Closes #506 from ijuma/poll-no-longer-throws-invalid-receive-exception (cherry picked from commit b5401f291a16977992c50f0a66d9f02aea07bbe7) Signed-off-by: Jun Rao <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/33809f5e Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/33809f5e Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/33809f5e Branch: refs/heads/0.9.0 Commit: 33809f5ebc9478528d6b5d150435d3169c5a64a4 Parents: 8c37009 Author: Ismael Juma <[email protected]> Authored: Thu Nov 12 07:19:02 2015 -0800 Committer: Jun Rao <[email protected]> Committed: Thu Nov 12 07:19:10 2015 -0800 ---------------------------------------------------------------------- core/src/main/scala/kafka/network/SocketServer.scala | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/33809f5e/core/src/main/scala/kafka/network/SocketServer.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/network/SocketServer.scala b/core/src/main/scala/kafka/network/SocketServer.scala index 1b94c86..cb38153 100644 --- a/core/src/main/scala/kafka/network/SocketServer.scala +++ b/core/src/main/scala/kafka/network/SocketServer.scala @@ -33,7 +33,7 @@ import kafka.server.KafkaConfig import kafka.utils._ import org.apache.kafka.common.MetricName import org.apache.kafka.common.metrics._ -import org.apache.kafka.common.network.{Selector => KSelector, LoginType, Mode, ChannelBuilders, InvalidReceiveException} +import org.apache.kafka.common.network.{Selector => KSelector, LoginType, Mode, ChannelBuilders} import org.apache.kafka.common.security.auth.KafkaPrincipal import org.apache.kafka.common.protocol.SecurityProtocol import org.apache.kafka.common.protocol.types.SchemaException @@ -417,9 +417,6 @@ private[kafka] class Processor(val id: Int, swallow(closeAll()) shutdownComplete() throw e - case e: InvalidReceiveException => - // Log warning and continue since Selector already closed the connection - warn("Connection was closed due to invalid receive. Processor will continue handling other connections") } selector.completedReceives.asScala.foreach { receive => try {
