That's definitely means it's not up to date to the protocol, I'm tried the
java client and it was working with latest 0.8 api.
Not sure about any other languages.
Tim
On Sat, Aug 10, 2013 at 2:55 PM, Mark <static.void....@gmail.com> wrote:
> Are all Kafka clients working with the latest version of Kafka?
>
> I tried the kafka-rb client and a simple example listed in the README but
> I keep getting a nasty error
> require 'kafka'
> producer = Kafka::Producer.new
> message = Kafka::Message.new("some random message content")
> producer.push(message)
>
> [2013-08-10 14:49:52,166] ERROR Closing socket for /127.0.0.1 because of
> error (kafka.network.Processor)
> java.nio.BufferUnderflowException
> at java.nio.HeapByteBuffer.get(HeapByteBuffer.java:127)
> at java.nio.ByteBuffer.get(ByteBuffer.java:675)
> at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:38)
> at
> kafka.api.ProducerRequest$$anonfun$1.apply(ProducerRequest.scala:40)
> at
> kafka.api.ProducerRequest$$anonfun$1.apply(ProducerRequest.scala:38)
> at
> scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:227)
> at
> scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:227)
> at
> scala.collection.immutable.Range$ByOne$class.foreach(Range.scala:282)
> at
> scala.collection.immutable.Range$$anon$1.foreach(Range.scala:274)
> at
> scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:227)
> at scala.collection.immutable.Range.flatMap(Range.scala:39)
> at kafka.api.ProducerRequest$.readFrom(ProducerRequest.scala:38)
> at kafka.api.RequestKeys$$anonfun$1.apply(RequestKeys.scala:34)
> at kafka.api.RequestKeys$$anonfun$1.apply(RequestKeys.scala:34)
> at
> kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:49)
> at kafka.network.Processor.read(SocketServer.scala:345)
> at kafka.network.Processor.run(SocketServer.scala:245)
> at java.lang.Thread.run(Thread.java:680)
>
>
