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

The Next Generation of the Consumer Rebalance Protocol

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • None
    • None

    Attachments

      Issue Links

        blocks

        Improvement - An improvement or enhancement to an existing feature or task. KAFKA-14524 Modularize `core` monolith

        • Major - Major loss of function.
        • Open
        links to

        Web Link GitHub Pull Request #13203

        Web Link GitHub Pull Request #14090

        Web Link GitHub Pull Request #14327

        mentioned in

        Page Loading...

        1.
        		 Automated protocol should support namespace Sub-task Open David Jacot
        2.
        		 Add ConsumerGroupPrepareAssignment API Sub-task Open Unassigned
        3.
        		 Add ConsumerGroupInstallAssignment API Sub-task Open Unassigned
        4.
        		 Extend DescribeConfigs API to support group configs Sub-task Open Jimmy Wang
        5.
        		 Extend AlterIncrementalConfigs API to support group config Sub-task In Progress Lan Ding
        6.
        		 Implement regex subscriptions Sub-task In Progress Lianet Magrans
        7.
        		 OffsetCommit API Version 9 Sub-task Patch Available Alexandre Dupriez
        8.
        		 OffsetFetch API Version 9 Sub-task In Progress Alexandre Dupriez
        9.
        		 Add ConsumerGroupHeartbeat API to AuthorizerIntegrationTest Sub-task Open Unassigned
        10.
        		 Add support of topic id for OffsetCommitRequests in CommitRequestManager Sub-task Open Alexandre Dupriez
        11.
        		 Add ACL Authorizer integration test for authorized OffsetCommits with an unknown topic Sub-task Open Alexandre Dupriez
        12.
        		 Propagate Topic Ids to the Group Coordinator for Offset Fetch Sub-task Open Alexandre Dupriez
        13.
        		 Refactor ApiMessageAndVersion/Record Sub-task Open David Jacot
        14.
        		 Validate that all partitions are assigned in TargetAssignmentBuilder Sub-task Open Unassigned
        15.
        		 Consolidate all the group coordinator configs Sub-task Open Unassigned
        16.
        		 Define constants for record types Sub-task Open Unassigned
        17.
        		 Consider replacing Subscription Metadata by a hash Sub-task Open David Jacot
        18.
        		 Add histogram metrics to GroupCoordinatorRuntimeMetrics Sub-task Open Unassigned
        19.
        		 Migrate existing integration tests to run old protocol in new coordinator Sub-task Open Dongnuo Lyu
        20.
        		 Make General Assignor's rebalance incremental Sub-task Open Unassigned
        21.
        		 Client support for OffsetFetch and OffsetCommit with topic ID Sub-task Open Lianet Magrans
        22.
        		 Group commit/callbacks triggering logic Sub-task Open Lianet Magrans
        23.
        		 Review minimal effort approach on consumer last heartbeat on unsubscribe Sub-task Open Lianet Magrans
        24.
        		 Review consumer onPartitionsAssigned called with empty partitions Sub-task Open Lianet Magrans
        25.
        		 Topic ID integration in consumer subscription state Sub-task Open Lianet Magrans
        26.
        		 group size counters do not reflect the actual sizes when operations fail Sub-task Open Jeff Kim
        27.
        		 Move code style exceptions from suppressions.xml to the code Sub-task Open David Jacot
        28.
        		 Review fenced member unsubscribe/subscribe callbacks interaction Sub-task Open Quoc Phong Dang
        29.
        		 Add event rate in GroupCoordinatorRuntimeMetrics Sub-task Open Jeff Kim
        30.
        		 add metric to measure time spent in purgatory Sub-task Open Jeff Kim
        31.
        		 getOrMaybeCreateClassicGroup should not thrown GroupIdNotFoundException Sub-task Open David Jacot
        32.
        		 Optimize toTopicPartitions with ConsumerProtocolSubscription Sub-task Open Dongnuo Lyu
        33.
        		 Adjust classicGroupJoinToConsumerGroup to add subscription model Sub-task Open Dongnuo Lyu

        Activity

          People

            dajac David Jacot
            dajac David Jacot
            Votes:
            0 Vote for this issue
            Watchers:
            13 Start watching this issue

            Dates

              Created:
              Updated:

              Time Tracking

                Estimated:
                Original Estimate - 672h
                672h
                Remaining:
                Remaining Estimate - 672h
                672h
                Logged:
                Time Spent - Not Specified
                Not Specified