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

Subsequent calls of ConsumerConnector.createMessageStreams cause Consumer offset to be incorrect

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Auto Closed
    • Affects Version/s: 0.7
    • Fix Version/s: None
    • Component/s: clients
    • Labels:
      None

      Description

      When calling ConsumerConnector.createMessageStreams in rapid succession, the Consumer offset is incorrectly advanced causing the consumer to lose messages. This seems to happen when createMessageStreams is called before the rebalancing triggered by the previous call to createMessageStreams has completed.

        Attachments

        1. kafka.log
          7 kB
          David Arthur

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              mumrah David Arthur
            • Votes:
              0 Vote for this issue
              Watchers:
              8 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: