[KAFKA-4073] MirrorMaker should handle mirroring messages w/o timestamp better

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.0.1
• Fix Version/s: 0.10.0.2, 0.10.1.0
• Assignee: Ismael Juma
• Reporter: Jun Rao
• Created: 22/Aug/16 19:28
• Updated: 23/Aug/16 04:50
• Resolved: 23/Aug/16 04:50

Description

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)

Issue Links

• links to: GitHub Pull Request #1773