clear query| facets| time Search criteria: .   Results from 111 to 120 from 186 (0.0s).
Loading phrases to help you
refine your search...
version of zookeeper - Kafka - [mail # user]
...The ZooKeeper API has been stable for a while, I do not suspect there would be any problems between 3.3.4 and 3.4.x. Personally, I have run Kafka 0.7.x with ZooKeeper 3.4.3 with no problems ...
   Author: David Arthur , 2012-11-13, 13:55
[expand - 1 more] - Kafka stream processing framework? - Kafka - [mail # dev]
...Prashanth,  Storm seems to be more focused on data flow between Storm processors (spout? bolt? i forget). My particular use case follows this pattern:  * read id from kafka queue *...
   Author: David Arthur , 2012-11-08, 16:38
[expand - 1 more] - Committing offsets - Kafka - [mail # user]
...Thanks, Jun. This is what I was looking for. I did a little experimentation and found that if I crashed the JVM immediately after consuming a message, the offset is not always changed. I'm g...
   Author: David Arthur , 2012-11-08, 16:32
Multi Costumer and Broker - Kafka - [mail # dev]
...Read through the quick start on the project page http://incubator.apache.org/kafka/quickstart.html  Kafka consumers need to be in the same "consumer group" in order to act as one (one m...
   Author: David Arthur , 2012-11-08, 15:11
Scenarios of Hadoop producers and consumers - Kafka - [mail # user]
...Indeed Hadoop is not the ideal platform for stream processing, but there are plenty of use cases for Kakfa + Hadoop. I use it to consolidate log data from many different systems into HDFS. I...
   Author: David Arthur , 2012-10-31, 01:05
Kafka Python client - Kafka - [mail # user]
...I sent this around on the devs list, but neglected to include the users list. A few weeks ago I put together a "protocol" Python client for Kafka. It doesn't do any of the ZooKeeper/consumer...
   Author: David Arthur , 2012-10-29, 18:12
How to feed MessagePack object to Kafka? - Kafka - [mail # user]
...kafka.message.Message has a constructor that takes in a byte array. MessagePack.write takes in an Object and returns a byte array. You just need to glue the two together in a kafka.serialize...
   Author: David Arthur , 2012-10-29, 18:01
Is is possible to send Kryo serialized object to Kafka ? - Kafka - [mail # user]
...Messages in Kafka are just bytes, so as long as you can generate a byte array (byte[]) you can use anything with Kafka. You will need to implement adaptors for your serialization library tha...
   Author: David Arthur , 2012-10-29, 17:53
Birds of a Feather Kafka table - Kafka - [mail # user]
...+1 see you all there  Sent from my phone  On Oct 24, 2012, at 9:13 AM, Felix GV  wrote:  > For the people at Hadoop World, we'll meet at table 9, during today's lunch....
   Author: David Arthur , 2012-10-24, 13:50
[expand - 1 more] - Trouble producing gzip messages - Kafka - [mail # dev]
...Answered my own question:  The gzipped payload is an encoded MessageSet itself, not just the gzip of a single message's payload.  -David  On Sep 26, 2012, at 7:43 PM, David Ar...
   Author: David Arthur , 2012-09-27, 02:37