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ć
