RE: Consume more than produce

2014-08-11 Thread Guy Doulberg
If you can't see the image, I uploaded it to dropbox https://www.dropbox.com/s/gckn4gt7gv26l9w/graph.png From: Guy Doulberg [mailto:guy.doulb...@perion.com] Sent: Monday, August 11, 2014 4:58 PM To: users@kafka.apache.org Subject: RE: Consume more than produce Hey I had an issue i

RE: Consume more than produce

2014-08-11 Thread Guy Doulberg
ugust 04, 2014 2:12 PM To: users@kafka.apache.org Subject: RE: Consume more than produce Hi Daniel I count once when producing and count once when consuming, the timestamp is calculated once before producing, and it is being attached to the msg so the consumer will use the same TS to count

RE: Consume more than produce

2014-08-04 Thread Guy Doulberg
] Sent: Monday, August 04, 2014 12:35 PM To: users@kafka.apache.org Subject: Re: Consume more than produce Hi Guy In your reconciliation, where was the time stamp coming from? Is it possible that messages were delivered several times but your calculations only counted each unique event? Daniel

Re: Consume more than produce

2014-08-04 Thread Daniel Compton
ducer ACK value? > > In my code I don't have a retry mechanism, the Kafka producer API has a retry > mechanism? > > > -Original Message- > From: Guozhang Wang [mailto:wangg...@gmail.com] > Sent: Friday, August 01, 2014 6:08 PM > To: users@kafka.apache.org >

RE: Consume more than produce

2014-08-03 Thread Guy Doulberg
nsume more than produce What is the ack value used in the producer? On Fri, Aug 1, 2014 at 1:28 AM, Guy Doulberg wrote: > Hey, > > > After a year or so I have Kafka as my streaming layer in my > production, I decided it is time to audit, and to test how many events > do I lo

Re: Consume more than produce

2014-08-01 Thread Jun Rao
Do you have producer retries (due to broker failure) in those minutes when you see a diff? Thanks, Jun On Fri, Aug 1, 2014 at 1:28 AM, Guy Doulberg wrote: > Hey, > > > After a year or so I have Kafka as my streaming layer in my production, I > decided it is time to audit, and to test how many

Re: Consume more than produce

2014-08-01 Thread Guozhang Wang
What is the ack value used in the producer? On Fri, Aug 1, 2014 at 1:28 AM, Guy Doulberg wrote: > Hey, > > > After a year or so I have Kafka as my streaming layer in my production, I > decided it is time to audit, and to test how many events do I lose, if I > lose events at all. > > > I discove

Re: Consume more than produce

2014-08-01 Thread Steve Morin
You have to remember statsd uses udp and possibly lossy which might account for the errors. -Steve On Fri, Aug 1, 2014 at 1:28 AM, Guy Doulberg wrote: > Hey, > > > After a year or so I have Kafka as my streaming layer in my production, I > decided it is time to audit, and to test how many event

Consume more than produce

2014-08-01 Thread Guy Doulberg
Hey, After a year or so I have Kafka as my streaming layer in my production, I decided it is time to audit, and to test how many events do I lose, if I lose events at all. I discovered something interesting which I can't explain. The producer produces less events that the consumer group con