Re: Dilemma - ZK consumer woes - upgrade to 0.8?

2013-06-07 Thread Jun Rao
Which version of ZK are you using? Thanks, Jun On Fri, Jun 7, 2013 at 12:20 PM, Evan Chan wrote: > [ Sorry if this mail is duplicated, this is my fourth try sending this > message] > > Hey guys, > > I sincerely apologize if this has been covered before, I haven't quite > found a similar situa

Re: Kafka Messages

2013-06-07 Thread Jonathan Creasy
*We have a mixture of:* ERROR: something bad happened *Some logs are "actions":* user upload a file user collaborated a file *Some logs are metrics:* counter:webapp.rps:+1 -Jonathan On Fri, Jun 7, 2013 at 8:12 PM, Mark wrote: > Are these always log files in the sense of log files or do th

Re: Kafka Messages

2013-06-07 Thread Mark
Are these always log files in the sense of log files or do they also contain some event data.. i.e. Product A was purchased or User A just signed in, etc? On Jun 7, 2013, at 6:53 PM, Jonathan Creasy wrote: > Correct, we essentially use the logs as an additional buffer in case of > outage in th

Re: Kafka Messages

2013-06-07 Thread Jonathan Creasy
Correct, we essentially use the logs as an additional buffer in case of outage in the pipeline. Typically though, messages are produces as soon as they are written. -Jonathan On Fri, Jun 7, 2013 at 6:06 PM, Mark wrote: > Ok so in your use case instead of your application(s) writing directly t

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Jonathan Hodges
Thanks so much for your replies. This has been a great help understanding Rabbit better with having very little experience with it. I have a few follow up comments below. > While you are correct the payload is a much bigger concern, managing the > metadata and acks centrally on the broker acros

Re: Kafka Messages

2013-06-07 Thread Mark
Ok so in your use case instead of your application(s) writing directly to Kafka you instead have a separate process running that will tail log files and ship them over to Kafka. Is that correct? On Jun 7, 2013, at 5:33 PM, Jonathan Creasy wrote: > I recommend Kafka or Flume-NG for this. > > O

Re: Kafka Messages

2013-06-07 Thread Jonathan Creasy
I recommend Kafka or Flume-NG for this. Our Analytics team is using a Kafka Producer on each server to tail logs and ship them to Kafka. We use Oozie to schedule a MapReduce consumer every few minutes to read all the Kafka topics into HDFS. We use Kafka as a buffer, we keep a few weeks of data th

Re: Kafka Messages

2013-06-07 Thread Mark
Like I said, Im a bit confused. I see the terms "events", "messages" and "logs" and not quite sure what to make of it. We are trying to determine the best way to aggregate all of our logs for processing in Hadoop. Kafka seems to fit this bill nicely however I want to know If its suited for othe

Re: Kafka Messages

2013-06-07 Thread Alexis Richardson
On Sat, Jun 8, 2013 at 1:08 AM, Mark wrote: > Im a bit confused on the concept of a "message" in Kafka. How does this > differ, if at all, from a message in RabbitMQ? It seems to me that Kafka is > better suited for very write intensive "messages" like log data but RabbitMQ > may be a better f

Kafka Messages

2013-06-07 Thread Mark
Im a bit confused on the concept of a "message" in Kafka. How does this differ, if at all, from a message in RabbitMQ? It seems to me that Kafka is better suited for very write intensive "messages" like log data but RabbitMQ may be a better fit for traditional "messages"… i.e. "Product Purchase

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Alexis Richardson
Jonathan, On Fri, Jun 7, 2013 at 7:42 PM, Jonathan Hodges wrote: > Sorry I forgot to add this RabbitMQ link as well as it also seems to > indicate the copying of messages to multiple queues with a topic exchange. > > http://www.rabbitmq.com/tutorials/tutorial-five-python.html "Copy" is not menti

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Alexis Richardson
Jonathan, On Fri, Jun 7, 2013 at 7:03 PM, Jonathan Hodges wrote: > Hi Alexis, > > I appreciate your reply and clarifications to my misconception about > Rabbit, particularly on the copying of the message payloads per consumer. Thank-you! > It sounds like it only copies metadata like the cons

RE: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Sybrandy, Casey
IIRC, I think I tried to use stunnel with Kafka once and it worked fine and the configuration wasn't too bad, at least for a simple configuration. -Original Message- From: Dragos Manolescu [mailto:dragos.manole...@servicenow.com] Sent: Friday, June 07, 2013 4:51 PM To: users@kafka.apache

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Dragos Manolescu
Thank you Marc (and others) for jumping in and sharing your perspectives! A feature that Kafka doesn't currently support while RabbitMQ does (since about a year ago, I don't remember exactly) is SSL support. I realize that one can set up a tunnel between data centers, etc.; that would require more

Re: Dilemma - ZK consumer problems - upgrade to 0.8?

2013-06-07 Thread Neha Narkhede
Which version of ZK are you using ? On Fri, Jun 7, 2013 at 12:15 PM, Evan Chan wrote: > Hey guys, > > I sincerely apologize if this has been covered before, I haven't quite > found a similar situation. > > We are using Kafka 0.7.2 in production, and we are using the ZK high level > Scala consum

Dilemma - ZK consumer woes - upgrade to 0.8?

2013-06-07 Thread Evan Chan
[ Sorry if this mail is duplicated, this is my fourth try sending this message] Hey guys, I sincerely apologize if this has been covered before, I haven't quite found a similar situation. We are using Kafka 0.7.2 in production, and we are using the ZK high level Scala consumer. However, we fin

Dilemma - ZK consumer problems - upgrade to 0.8?

2013-06-07 Thread Evan Chan
Hey guys, I sincerely apologize if this has been covered before, I haven't quite found a similar situation. We are using Kafka 0.7.2 in production, and we are using the ZK high level Scala consumer. However, we find the ZK consumer very unstable. It would work for one or two weeks, then sudden

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Jonathan Hodges
Sorry I forgot to add this RabbitMQ link as well as it also seems to indicate the copying of messages to multiple queues with a topic exchange. http://www.rabbitmq.com/tutorials/tutorial-five-python.html Maybe I am misunderstanding and topic exchange wouldn't be the approach to take with Rabbit i

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Jonathan Hodges
Hi Alexis, I appreciate your reply and clarifications to my misconception about Rabbit, particularly on the copying of the message payloads per consumer. It sounds like it only copies metadata like the consumer state i.e. position in the topic messages. I don’t have experience with Rabbit and wa

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Alexis Richardson
Jun, On Fri, Jun 7, 2013 at 4:23 PM, Jun Rao wrote: > Hi, Alex, > > Thanks for sharing your thoughts here. Your understand of Kafka is correct > and your analysis is very helpful. Just a couple of followup questions on > RabbitMQ. > > 1. How do people typically scale out RabbitMQ? In Kafka, we ha

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Jun Rao
Hi, Alex, Thanks for sharing your thoughts here. Your understand of Kafka is correct and your analysis is very helpful. Just a couple of followup questions on RabbitMQ. 1. How do people typically scale out RabbitMQ? In Kafka, we have this notion of a cluster that can include multiple brokers. Bro

Re: java.lang.NumberFormatException: null - when producer tries to send message to Kafka queue

2013-06-07 Thread Andrea Gazzarini
Hi, looking at the stack trace It seems to me you are using Kafka 0.7.0. Well, I think the issue has something to do with broker(s) registration (i.e Zookeeper) so you should check the startup messages on Kafka and eventually the Zookeeper logs, I'm quite sure you will find something there. Th

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Alexis Richardson
Hi Alexis from Rabbit here. I hope I am not intruding! It would be super helpful if people with questions, observations or moans posted them to the rabbitmq list too :-) A few comments: * Along with ZeroMQ, I consider Kafka to be one of the interesting and useful messaging projects out there.

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Marc Labbe
Nice of you to reply Alexis and clarify things! FWIW, I personally like Rabbit very much and I am pushing to use it for other purposes at my company. It's flexibility, ease of use and even documentation is really top if you compare with other options. I might have explained some of my points a bit

Re: Arguments for Kafka over RabbitMQ ?

2013-06-07 Thread Alexis Richardson
Hi Alexis from Rabbit here. I hope I am not intruding! It would be super helpful if people with questions, observations or moans posted them to the rabbitmq list too :-) A few comments: * Along with ZeroMQ, I consider Kafka to be one of the interesting and useful messaging projects out there.