Re: Is kafka message timestamp preserved in mirror maker

2016-06-01 Thread Gerard Klijs
Although I think it should have been an included option, it's very easy to create and use your own message handler with the mirror maker. You can simply copy the timestamp and type from the consumerecord to the producerecord. On Wed, Jun 1, 2016 at 5:48 PM Gwen Shapira wrote:

Re: Is kafka message timestamp preserved in mirror maker

2016-06-01 Thread Gwen Shapira
The intent was definitely as you described, but I think we forgot to actually modify the code accordingly. Do you mind opening a JIRA on the issue? Gwen On Wed, Jun 1, 2016 at 4:13 PM, tao xiao wrote: > Hi, > > As per the description in KIP-32 the timestamp of Kafka

Is kafka message timestamp preserved in mirror maker

2016-06-01 Thread tao xiao
Hi, As per the description in KIP-32 the timestamp of Kafka message is unchanged mirrored from one cluster to another if createTime is used. But I tested with mirror maker in Kafka-0.10 this doesn't seem the case. The timestamp of the same message is different in source and target. I checked the