java.nio.channels.ClosedChannelException

[Sa Li]

Hi, All

I send messages from one VM to production, but getting such error

[2015-01-30 18:43:44,810] WARN Failed to send producer request with
correlation id 126 to broker 101 with data for partitions
[test-rep-three,5],[test-rep-three,2]
(kafka.producer.async.DefaultEventHandler)
java.nio.channels.ClosedChannelException
       at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
       at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)
       at
kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
       at
kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SyncProducer.scala:103)
       at
kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:103)
       at
kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:103)
       at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
       at
kafka.producer.SyncProducer$$anonfun$send$1.apply$mcV$sp(SyncProducer.scala:102)
       at
kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:102)
       at
kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:102)
       at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
       at kafka.producer.SyncProducer.send(SyncProducer.scala:101)
       at
kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:256)
       at
kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:107)
       at
kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:99)
       at
scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:772)
       at
scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:98)
       at
scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:98)
       at
scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:226)
       at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39)
       at scala.collection.mutable.HashMap.foreach(HashMap.scala:98)

I actually had this kind of error before in another VM, now it works fine
in that VM, but when I start a new VM and get kafka build in this new VM,
it comes again, really can't recall what did I do to fix this problem
before, any ideas?  BTW, I telnet, it says connected.

thanks

AL

-- 

Alec Li