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

Return more useful information from ConsumerGroupCommand for consumer groups that are rebalancing or manually assigned

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Duplicate
    • 0.9.0.1, 0.10.0.0, 0.10.0.1
    • None
    • consumer, tools
    • None

    Description

      For consumers which are manually assigned topic partitions, or for offsets which are otherwise manually committed to brokers using the new consumer API, the existing ConsumerGroupCommand tools are operationally insufficient.
      There are many use cases in production operation when it is important to be able to easily retrieve the stored offsets and calculated lag of a consumer group, even if the group is rebalancing or partition assignment information is indeterminate. Often these cases involve a misbehaving or crashed client application, and having the ConsumerGroupCommand return Consumer group `myGroupID` does not exist or is rebalancing. instead of the information it does know is not very helpful. Additionally, when manual offset commits are used, or the automatic consumer group subscription management is not used, the same message is returned by the tool. In these cases, the offsets are actually stored and available even though the broker/coordinator doesn't have information about partition ownership.
      Previously, this was a non-issue as a ZK client could be leveraged relatively easily to get important information like the last stored offset positions, or consumer-offset-checker would return more information in its responses. With the new consumer, however, the process for getting offset and lag is not as straightforward, and tools to provide this information at the operational level are necessary as part of a Kafka installation.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              graphex Sean McKibben
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: