Dear Michael, Thanks for sharing this information with me.
I am aware of the fact that each message has a timestamp indicating either the log append or creation time. But in my case, this is not enough since I want to derive the consumption time of messages. The reason for this is because we are currently in the process of an empirical research benchmarking several stream processing engines. Anyhow, I’ll take a look at the intercept classes. Dominik > On 1 Nov 2016, at 14:40, Mickael Maison <mickael.mai...@gmail.com> wrote: > > Hi Dominik, > > On both the consumer and producer you can use the > "interceptor.classes" config to specify classes that intercept and can > modify records when they are sent/received. > Also as of Kafka 0.10, messages have a timestamp field. See > http://kafka.apache.org/0101/javadoc/org/apache/kafka/clients/consumer/ConsumerRecord.html#timestamp(). > > On Tue, Nov 1, 2016 at 12:17 PM, Dominik Safaric > <dominiksafa...@gmail.com> wrote: >> Is it possible to somehow modify the Kafka message payload before being sent >> to the consumer for consumption? Such as for example adding a timestamp to >> the current message payload indicating the time of message consumption. >> >> Dominik Šafarić
