Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka >> mail # user >> Kafka 08 clients


+
Mark 2013-08-10, 21:55
+
Timothy Chen 2013-08-10, 22:08
Copy link to this message
-
Re: Kafka 08 clients
bpot/poseidon on github is a ruby 0.8 client, works fine for me

Sent from my iPhone

On Aug 10, 2013, at 3:08 PM, Timothy Chen <[EMAIL PROTECTED]> wrote:

> 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 <[EMAIL PROTECTED]> 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)
>>
>>

 
+
Mark 2013-08-11, 01:31
+
Jun Rao 2013-08-12, 04:07
+
Andrew Otto 2013-08-12, 13:51
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB