[
https://issues.apache.org/jira/browse/KAFKA-4101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15447337#comment-15447337
]
Jason Gustafson edited comment on KAFKA-4101 at 8/29/16 11:03 PM:
------------------------------------------------------------------
[~andrey-sra] I think this might be fixed by KAFKA-3341 (in 0.10.0.0
unfortunately). Was there any additional context in the log? I'm looking for an
error messaging saying something like "Closing socket for [host] because of
error."
was (Author: hachikuji):
[~andrey-sra] I think this might be fixed by KAFKA-3341 (in 0.10.0.0
unfortunately). Was there any additional context in the log? I'm looking for an
error messaging saying something like "Closing socket for {host} because of
error."
> java.lang.IllegalStateException in
> org.apache.kafka.common.network.Selector.channelOrFail
> -----------------------------------------------------------------------------------------
>
> Key: KAFKA-4101
> URL: https://issues.apache.org/jira/browse/KAFKA-4101
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.9.0.1
> Environment: Ubuntu 14.04, AWS deployment, under heavy network load
> Reporter: Andrey Savov
>
> {code}
> at org.apache.kafka.common.network.Selector.channelOrFail(Selector.java:467)
> at org.apache.kafka.common.network.Selector.mute(Selector.java:347)
> at
> kafka.network.Processor$$anonfun$run$11.apply(SocketServer.scala:434)
> at
> kafka.network.Processor$$anonfun$run$11.apply(SocketServer.scala:421)
> at scala.collection.Iterator$class.foreach(Iterator.scala:742)
> at scala.collection.AbstractIterator.foreach(Iterator.scala:1194)
> at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
> at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> at kafka.network.Processor.run(SocketServer.scala:421)
> at java.lang.Thread.run(Thread.java:745)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
