Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-4073

MirrorMaker should handle mirroring messages w/o timestamp better

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.10.0.1
    • 0.10.0.2, 0.10.1.0
    • None
    • None

    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)

      Attachments

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            ijuma Ismael Juma
            junrao Jun Rao
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment