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

Mirror maker doesn't commit offset with new consumer when there is no more messages

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.9.0.0
    • Fix Version/s: 0.9.0.1
    • Component/s: None
    • Labels:
      None

      Description

      Mirror maker doesn't commit messages with new consumer enabled when messages are sent to source within the time range that is smaller than commit interval and no more messages are sent afterwards.

      The steps to reproduce:

      1. Start mirror maker.
      2. The default commit interval is 1 min. Send message for less than 1 min for example 10 seconds.
      3. Don't send more messages.
      4. Check committed offset with group command. The lag remains unchanged for ever even though the messages have been sent to destination.

        Attachments

          Activity

            People

            • Assignee:
              xiaotao183 TAO XIAO
              Reporter:
              xiaotao183 TAO XIAO
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: