Re: Measure latency from Source to Sink

2018-07-20 Thread antonio saldivar
-cookbook-implementing-custom-interceptors/ > > > > > https://medium.com/@bkvarda/building-a-custom-flume-interceptor-8c7a55070038 > > > > > > > > *From: *antonio saldivar > *Date: *Friday, July 20, 2018 at 9:57 AM > *To: *"Thakrar, Jayesh"

Re: Measure latency from Source to Sink

2018-07-20 Thread Thakrar, Jayesh
-implementing-custom-interceptors/ https://medium.com/@bkvarda/building-a-custom-flume-interceptor-8c7a55070038 From: antonio saldivar Date: Friday, July 20, 2018 at 9:57 AM To: "Thakrar, Jayesh" Cc: "users@kafka.apache.org" Subject: Re: Measure latency from Source to Sink Hi A

Re: Measure latency from Source to Sink

2018-07-20 Thread antonio saldivar
Hi Actually I am running the app I a single node this is for a POC, I was not aware of the custom interceptors do you have an example of this? Best Regards El vie., 20 jul. 2018 a las 9:20, Thakrar, Jayesh (< jthak...@conversantmedia.com>) escribió: > See if you can use a custom interceptors fo

Re: Measure latency from Source to Sink

2018-07-20 Thread Thakrar, Jayesh
See if you can use a custom interceptors for this. The only fuzzy thing is that the clocks would be different so I would be a little skeptical of its accuracy. I have heard of some companies who have a special topic in which they insert test msgs and then read them back - using the same machine f

Measure latency from Source to Sink

2018-07-19 Thread antonio saldivar
Hello I am developing an application using kafka and flink, I need to be able to measure the latency from the producer and when it comes out to the sink. I can append the timestamp in Millisecond when I send the trxn from the producer but at the end how to append the timestamp when it comes out t

Measure Latency from Source to Sink

2018-07-19 Thread antonio saldivar
Hello I am developing an application using kafka and flink, I need to be able to measure the latency from the producer and when it comes out to the sink. I can append the timestamp in Millisecond when I send the trxn from the producer but at the end how to append the timestamp when it comes out t