Hello,
As for 1), my suspicion is that this is caused by chaining. If the map
function is chained to the kafka source then the latency markers are
always immediately forwarded, regardless of what your map function is doing.
If the map function is indeed chained to the source, could you try
Hi,
I would like to understand how to measure the latency of a record.
I have set up a simple project with a Kafka consumer that reads from a
topic and performs a simple map (with a thread sleep inside).
In order to measure the latency of this mapper I have added
