kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mickael Maison <mickael.mai...@gmail.com>
Subject Re: Modify in-flight messages
Date Tue, 01 Nov 2016 13:40:35 GMT
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
<dominiksafaric@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ć

Mime
View raw message