[
https://issues.apache.org/jira/browse/KAFKA-4073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432007#comment-15432007
]
ASF GitHub Bot commented on KAFKA-4073:
---------------------------------------
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/1773
KAFKA-4073: MirrorMaker should handle messages without timestamp correctly
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka kafka-4073-mirror-maker-timestamps
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1773.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1773
----
commit a85742cd7f0e55ce1eb9e82e3528817e0dea7adc
Author: Ismael Juma <[email protected]>
Date: 2016-08-23T02:25:31Z
Pass `null` as timestamp if source timestamp is `NO_TIMESTAMP`
----
> MirrorMaker should handle mirroring messages w/o timestamp better
> -----------------------------------------------------------------
>
> Key: KAFKA-4073
> URL: https://issues.apache.org/jira/browse/KAFKA-4073
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.10.0.1
> Reporter: Jun Rao
> Assignee: Ismael Juma
> Fix For: 0.10.1.0, 0.10.0.2
>
>
> Currently, if the 0.10.0.1 MirrorMaker reads a message w/o timestamp from the
> source cluster, it will hit the following exception. This was introduced in
> KAFKA-3787. So it only affects 0.10.0.1.
> [16/08/2016:18:26:41 PDT] [FATAL] [kafka.tools.MirrorMaker$MirrorMakerThread
> mirrormaker-thread-1]: [mirrormaker-thread-1] Mirror maker thread failure due
> to
> java.lang.IllegalArgumentException: Invalid timestamp -1
> at
> org.apache.kafka.clients.producer.ProducerRecord.<init>(ProducerRecord.java:60)
> at
> kafka.tools.MirrorMaker$defaultMirrorMakerMessageHandler$.handle(MirrorMaker.scala:678)
> at kafka.tools.MirrorMaker$MirrorMakerThread.run(MirrorMaker.scala:414)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
