[jira] [Resolved] (KAFKA-16735) Deprecate offsets.commit.required.acks in 3.8

[ https://issues.apache.org/jira/browse/KAFKA-16735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16735. - Resolution: Fixed > Deprecate offsets.commit.required.acks in

[jira] [Resolved] (KAFKA-16117) Add Integration test for checking if the correct assignor is chosen

[ https://issues.apache.org/jira/browse/KAFKA-16117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16117. - Fix Version/s: 3.8.0 Resolution: Fixed > Add Integration test for checking if

[jira] [Resolved] (KAFKA-15578) Run System Tests for Old protocol in the New Coordinator

[ https://issues.apache.org/jira/browse/KAFKA-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15578. - Resolution: Fixed > Run System Tests for Old protocol in the New Coordina

[jira] [Resolved] (KAFKA-16694) Remove rack aware code in assignors temporarily due to performance

[ https://issues.apache.org/jira/browse/KAFKA-16694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16694. - Fix Version/s: 3.8.0 Resolution: Fixed > Remove rack aware code in assignors temporar

[jira] [Created] (KAFKA-16770) Coalesce records into bigger batches

David Jacot created KAFKA-16770: --- Summary: Coalesce records into bigger batches Key: KAFKA-16770 URL: https://issues.apache.org/jira/browse/KAFKA-16770 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-16762) SyncGroup API for upgrading ConsumerGroup

[ https://issues.apache.org/jira/browse/KAFKA-16762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16762. - Fix Version/s: 3.8.0 Reviewer: David Jacot Resolution: Fixed > SyncGroup

[jira] [Resolved] (KAFKA-16793) Heartbeat API for upgrading ConsumerGroup

[ https://issues.apache.org/jira/browse/KAFKA-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16793. - Fix Version/s: 3.8.0 Reviewer: David Jacot Resolution: Fixed > Heartbeat

[jira] [Resolved] (KAFKA-16626) Uuid to String for subscribed topic names in assignment spec

[ https://issues.apache.org/jira/browse/KAFKA-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16626. - Fix Version/s: 3.8.0 Resolution: Fixed > Uuid to String for subscribed topic names

[jira] [Resolved] (KAFKA-16815) Handle FencedInstanceId on heartbeat for new consumer

[ https://issues.apache.org/jira/browse/KAFKA-16815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16815. - Fix Version/s: 3.8.0 Reviewer: David Jacot Resolution: Fixed > Han

[jira] [Resolved] (KAFKA-16831) CoordinatorRuntime should initialize MemoryRecordsBuilder with max batch size write limit

[ https://issues.apache.org/jira/browse/KAFKA-16831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16831. - Fix Version/s: 3.8.0 Reviewer: David Jacot Resolution: Fixed

[jira] [Resolved] (KAFKA-16625) Reverse Lookup Partition to Member in Assignors

[ https://issues.apache.org/jira/browse/KAFKA-16625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16625. - Fix Version/s: 3.8.0 Reviewer: David Jacot Resolution: Fixed > Reverse Loo

[jira] [Created] (KAFKA-16846) Should TxnOffsetCommit API fail all the offsets if any fails the validation?

David Jacot created KAFKA-16846: --- Summary: Should TxnOffsetCommit API fail all the offsets if any fails the validation? Key: KAFKA-16846 URL: https://issues.apache.org/jira/browse/KAFKA-16846 Project

[jira] [Resolved] (KAFKA-16371) Unstable committed offsets after triggering commits where metadata for some partitions are over the limit

[ https://issues.apache.org/jira/browse/KAFKA-16371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16371. - Fix Version/s: 3.8.0 3.7.1 Assignee: David Jacot Resolution

[jira] [Created] (KAFKA-16860) Introduce `group.version` feature flag

David Jacot created KAFKA-16860: --- Summary: Introduce `group.version` feature flag Key: KAFKA-16860 URL: https://issues.apache.org/jira/browse/KAFKA-16860 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-16832) LeaveGroup API for upgrading ConsumerGroup

[ https://issues.apache.org/jira/browse/KAFKA-16832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16832. - Fix Version/s: 3.8.0 Resolution: Fixed > LeaveGroup API for upgrading ConsumerGr

[jira] [Resolved] (KAFKA-16569) Target Assignment Format Change

[ https://issues.apache.org/jira/browse/KAFKA-16569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16569. - Resolution: Won't Do > Target Assignment Forma

[jira] [Resolved] (KAFKA-16722) Add ConsumerGroupPartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-16722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16722. - Reviewer: David Jacot Resolution: Fixed > Add ConsumerGroupPartitionAssignor interf

[jira] [Resolved] (KAFKA-16860) Introduce `group.version` feature flag

[ https://issues.apache.org/jira/browse/KAFKA-16860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16860. - Resolution: Fixed > Introduce `group.version` feature f

[jira] [Resolved] (KAFKA-16864) Copy on write in the Optimized Uniform Assignor

[ https://issues.apache.org/jira/browse/KAFKA-16864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16864. - Fix Version/s: 3.8.0 Resolution: Fixed > Copy on write in the Optimized Uniform Assig

[jira] [Resolved] (KAFKA-16861) Don't convert to group to classic if the size is larger than group max size

[ https://issues.apache.org/jira/browse/KAFKA-16861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16861. - Fix Version/s: 3.8.0 Resolution: Fixed > Don't convert to group to classic if

[jira] [Resolved] (KAFKA-16664) Re-add EventAccumulator.take(timeout)

[ https://issues.apache.org/jira/browse/KAFKA-16664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16664. - Fix Version/s: 3.8.0 Resolution: Fixed > Re-add EventAccumulator.take(time

[jira] [Resolved] (KAFKA-14701) More broker side partition assignor to common

[ https://issues.apache.org/jira/browse/KAFKA-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14701. - Fix Version/s: 3.8.0 Resolution: Fixed > More broker side partition assignor to com

[jira] [Resolved] (KAFKA-14509) Add ConsumerGroupDescribe API

[ https://issues.apache.org/jira/browse/KAFKA-14509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14509. - Fix Version/s: 3.8.0 Resolution: Fixed > Add ConsumerGroupDescribe

[jira] [Resolved] (KAFKA-16821) Create a new interface to store member metadata

[ https://issues.apache.org/jira/browse/KAFKA-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16821. - Fix Version/s: 3.8.0 Resolution: Fixed > Create a new interface to store member metad

[jira] [Created] (KAFKA-16930) UniformHeterogeneousAssignmentBuilder throws NPE when member has not subscriptions

David Jacot created KAFKA-16930: --- Summary: UniformHeterogeneousAssignmentBuilder throws NPE when member has not subscriptions Key: KAFKA-16930 URL: https://issues.apache.org/jira/browse/KAFKA-16930

[jira] [Resolved] (KAFKA-16930) UniformHeterogeneousAssignmentBuilder throws NPE when member has not subscriptions

[ https://issues.apache.org/jira/browse/KAFKA-16930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16930. - Resolution: Fixed > UniformHeterogeneousAssignmentBuilder throws NPE when member has

[jira] [Resolved] (KAFKA-16770) Coalesce records into bigger batches

[ https://issues.apache.org/jira/browse/KAFKA-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16770. - Resolution: Fixed > Coalesce records into bigger batc

[jira] [Resolved] (KAFKA-16673) Optimize toTopicPartitions with ConsumerProtocolSubscription

[ https://issues.apache.org/jira/browse/KAFKA-16673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16673. - Fix Version/s: 3.8.0 Resolution: Duplicate This was done as part of https://github.com

[jira] [Reopened] (KAFKA-16673) Optimize toTopicPartitions with ConsumerProtocolSubscription

[ https://issues.apache.org/jira/browse/KAFKA-16673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot reopened KAFKA-16673: - > Optimize toTopicPartitions with ConsumerProtocolSubscript

[jira] [Resolved] (KAFKA-16674) Adjust classicGroupJoinToConsumerGroup to add subscription model

[ https://issues.apache.org/jira/browse/KAFKA-16674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16674. - Resolution: Fixed This was done in https://github.com/apache/kafka/pull/15785. > Adj

[jira] [Resolved] (KAFKA-16317) Add event rate in GroupCoordinatorRuntimeMetrics

[ https://issues.apache.org/jira/browse/KAFKA-16317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16317. - Resolution: Won't Do > Add event rate in GroupCoordinatorRuntim

[jira] [Created] (KAFKA-16973) Fix caught-up condition

David Jacot created KAFKA-16973: --- Summary: Fix caught-up condition Key: KAFKA-16973 URL: https://issues.apache.org/jira/browse/KAFKA-16973 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-16673) Optimize toTopicPartitions with ConsumerProtocolSubscription

[ https://issues.apache.org/jira/browse/KAFKA-16673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16673. - Fix Version/s: 3.9.0 Resolution: Fixed > Optimize toTopicPartitions w

[jira] [Resolved] (KAFKA-16973) Fix caught-up condition

[ https://issues.apache.org/jira/browse/KAFKA-16973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16973. - Fix Version/s: 3.9.0 Resolution: Fixed > Fix caught-up condit

[jira] [Resolved] (KAFKA-16822) Abstract consumer group in coordinator to share functionality with share group

[ https://issues.apache.org/jira/browse/KAFKA-16822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16822. - Fix Version/s: 3.9.0 Resolution: Fixed > Abstract consumer group in coordinator to sh

[jira] [Created] (KAFKA-17058) Extend CoordinatorRuntime to support non-atomic writes

David Jacot created KAFKA-17058: --- Summary: Extend CoordinatorRuntime to support non-atomic writes Key: KAFKA-17058 URL: https://issues.apache.org/jira/browse/KAFKA-17058 Project: Kafka Issue

[jira] [Resolved] (KAFKA-17050) Revert group.version for 3.8 and 3.9

[ https://issues.apache.org/jira/browse/KAFKA-17050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17050. - Fix Version/s: 3.8.0 Resolution: Fixed > Revert group.version for 3.8 and

[jira] [Resolved] (KAFKA-17047) Refactor Consumer group and shared classes with Share to modern package

[ https://issues.apache.org/jira/browse/KAFKA-17047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17047. - Fix Version/s: 3.9.0 Resolution: Fixed > Refactor Consumer group and shared classes w

[jira] [Resolved] (KAFKA-17058) Extend CoordinatorRuntime to support non-atomic writes

[ https://issues.apache.org/jira/browse/KAFKA-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17058. - Fix Version/s: 3.9.0 Resolution: Fixed > Extend CoordinatorRuntime to support non-ato

[jira] [Resolved] (KAFKA-16944) Range assignor doesn't co-partition with stickiness

[ https://issues.apache.org/jira/browse/KAFKA-16944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16944. - Fix Version/s: 3.9.0 Resolution: Fixed > Range assignor doesn't co-partit

[jira] [Created] (KAFKA-17298) Update upgrade notes for 4.0

David Jacot created KAFKA-17298: --- Summary: Update upgrade notes for 4.0 Key: KAFKA-17298 URL: https://issues.apache.org/jira/browse/KAFKA-17298 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-17267) New group coordinator can return REQUEST_TIMED_OUT for OFFSET_FETCHes

[ https://issues.apache.org/jira/browse/KAFKA-17267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17267. - Fix Version/s: 4.0.0 Reviewer: David Jacot Assignee: Sean Quah

[jira] [Resolved] (KAFKA-17228) Static member using new protocol should always replace the one using the old protocol

[ https://issues.apache.org/jira/browse/KAFKA-17228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17228. - Fix Version/s: 4.0.0 Reviewer: David Jacot Resolution: Fixed > Static mem

[jira] [Resolved] (KAFKA-14511) Extend AlterIncrementalConfigs API to support group config

[ https://issues.apache.org/jira/browse/KAFKA-14511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14511. - Fix Version/s: 4.0.0 Resolution: Fixed > Extend AlterIncrementalConfigs API to supp

[jira] [Resolved] (KAFKA-14510) Extend DescribeConfigs API to support group configs

[ https://issues.apache.org/jira/browse/KAFKA-14510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14510. - Fix Version/s: 4.0.0 Resolution: Fixed > Extend DescribeConfigs API to support gr

[jira] [Resolved] (KAFKA-16576) New consumer fails with assert in consumer_test.py’s test_consumer_failure system test

[ https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16576. - Assignee: Dongnuo Lyu Resolution: Fixed Fixed by https://github.com/apache/kafka/pull

[jira] [Resolved] (KAFKA-17219) Adjust system test framework for new protocol consumer

[ https://issues.apache.org/jira/browse/KAFKA-17219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17219. - Assignee: Dongnuo Lyu Resolution: Fixed Fixed by https://github.com/apache/kafka/pull

[jira] [Resolved] (KAFKA-17295) New consumer fails with assert in consumer_test.py’s test_fencing_static_consumer system test

[ https://issues.apache.org/jira/browse/KAFKA-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17295. - Assignee: Dongnuo Lyu Resolution: Fixed Fixed by https://github.com/apache/kafka/pull

[jira] [Created] (KAFKA-17376) Use the new group coordinator by default in 4.0

David Jacot created KAFKA-17376: --- Summary: Use the new group coordinator by default in 4.0 Key: KAFKA-17376 URL: https://issues.apache.org/jira/browse/KAFKA-17376 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-16503) getOrMaybeCreateClassicGroup should not thrown GroupIdNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-16503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16503. - Resolution: Fixed Addressed by https://github.com/apache/kafka/pull/16919

[jira] [Resolved] (KAFKA-15061) CoordinatorPartitionWriter should reuse buffer

[ https://issues.apache.org/jira/browse/KAFKA-15061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15061. - Fix Version/s: 3.7.0 Resolution: Fixed > CoordinatorPartitionWriter should reuse buf

[jira] [Resolved] (KAFKA-15705) Add integration tests for Heartbeat API and GroupLeave API

[ https://issues.apache.org/jira/browse/KAFKA-15705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15705. - Fix Version/s: 3.7.0 Resolution: Fixed > Add integration tests for Heartbeat API

[jira] [Resolved] (KAFKA-15910) New group coordinator needs to generate snapshots while loading

[ https://issues.apache.org/jira/browse/KAFKA-15910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15910. - Fix Version/s: 3.7.0 Resolution: Fixed > New group coordinator needs to gener

[jira] [Resolved] (KAFKA-14516) Implement static membeship

[ https://issues.apache.org/jira/browse/KAFKA-14516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14516. - Fix Version/s: 3.7.0 Resolution: Fixed > Implement static membes

[jira] [Resolved] (KAFKA-15978) New consumer sends OffsetCommit with empty member ID

[ https://issues.apache.org/jira/browse/KAFKA-15978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15978. - Resolution: Fixed > New consumer sends OffsetCommit with empty member

[jira] [Resolved] (KAFKA-15574) Update states and transitions for membership manager state machine

[ https://issues.apache.org/jira/browse/KAFKA-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15574. - Fix Version/s: 3.7.0 Resolution: Fixed > Update states and transitions for members

[jira] [Resolved] (KAFKA-15981) update Group size only when groups size changes

[ https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15981. - Fix Version/s: 3.7.0 Resolution: Fixed > update Group size only when groups size chan

[jira] [Resolved] (KAFKA-15237) Implement write operation timeout

[ https://issues.apache.org/jira/browse/KAFKA-15237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15237. - Fix Version/s: 3.7.0 Resolution: Fixed > Implement write operation time

[jira] [Resolved] (KAFKA-15971) Re-enable consumer integration tests for new consumer

[ https://issues.apache.org/jira/browse/KAFKA-15971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15971. - Resolution: Fixed > Re-enable consumer integration tests for new consu

[jira] [Created] (KAFKA-16036) Add `group.coordinator.rebalance.protocols` and publish all new configs

David Jacot created KAFKA-16036: --- Summary: Add `group.coordinator.rebalance.protocols` and publish all new configs Key: KAFKA-16036 URL: https://issues.apache.org/jira/browse/KAFKA-16036 Project: Kafka

[jira] [Resolved] (KAFKA-16036) Add `group.coordinator.rebalance.protocols` and publish all new configs

[ https://issues.apache.org/jira/browse/KAFKA-16036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16036. - Resolution: Fixed > Add `group.coordinator.rebalance.protocols` and publish all new conf

[jira] [Created] (KAFKA-16040) Rename `Generic` to `Classic`

David Jacot created KAFKA-16040: --- Summary: Rename `Generic` to `Classic` Key: KAFKA-16040 URL: https://issues.apache.org/jira/browse/KAFKA-16040 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-16030) new group coordinator should check if partition goes offline during load

[ https://issues.apache.org/jira/browse/KAFKA-16030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16030. - Fix Version/s: 3.7.0 Resolution: Fixed > new group coordinator should check if partit

[jira] [Resolved] (KAFKA-15456) Add support for OffsetFetch version 9 in consumer

[ https://issues.apache.org/jira/browse/KAFKA-15456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15456. - Resolution: Fixed > Add support for OffsetFetch version 9 in consu

[jira] [Resolved] (KAFKA-16040) Rename `Generic` to `Classic`

[ https://issues.apache.org/jira/browse/KAFKA-16040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16040. - Resolution: Fixed > Rename `Generic` to `Clas

[jira] [Resolved] (KAFKA-14519) Add metrics to the new coordinator

[ https://issues.apache.org/jira/browse/KAFKA-14519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14519. - Fix Version/s: 3.7.0 Resolution: Fixed > Add metrics to the new coordina

[jira] [Resolved] (KAFKA-15870) Move new group coordinator metrics from Yammer to Metrics

[ https://issues.apache.org/jira/browse/KAFKA-15870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15870. - Fix Version/s: 3.7.0 Resolution: Fixed > Move new group coordinator metrics from Yam

[jira] [Resolved] (KAFKA-15982) Move GenericGroup state metrics to `GroupCoordinatorMetricsShard`

[ https://issues.apache.org/jira/browse/KAFKA-15982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15982. - Resolution: Duplicate Done in KAFKA-15870. > Move GenericGroup state metrics

[jira] [Created] (KAFKA-16118) Coordinator unloading fails when replica is deleted

David Jacot created KAFKA-16118: --- Summary: Coordinator unloading fails when replica is deleted Key: KAFKA-16118 URL: https://issues.apache.org/jira/browse/KAFKA-16118 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-16118) Coordinator unloading fails when replica is deleted

[ https://issues.apache.org/jira/browse/KAFKA-16118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16118. - Fix Version/s: 3.8.0 Resolution: Fixed > Coordinator unloading fails when replica

[jira] [Created] (KAFKA-16168) Implement GroupCoordinator.onPartitionsDeleted

David Jacot created KAFKA-16168: --- Summary: Implement GroupCoordinator.onPartitionsDeleted Key: KAFKA-16168 URL: https://issues.apache.org/jira/browse/KAFKA-16168 Project: Kafka Issue Type: Sub

[jira] [Resolved] (KAFKA-16147) Partition is assigned to two members at the same time

[ https://issues.apache.org/jira/browse/KAFKA-16147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16147. - Fix Version/s: 3.8.0 Resolution: Fixed > Partition is assigned to two members at

[jira] [Created] (KAFKA-16189) Extend admin to support ConsumerGroupDescribe API

David Jacot created KAFKA-16189: --- Summary: Extend admin to support ConsumerGroupDescribe API Key: KAFKA-16189 URL: https://issues.apache.org/jira/browse/KAFKA-16189 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-16107) Ensure consumer does not start fetching from added partitions until onPartitionsAssigned completes

[ https://issues.apache.org/jira/browse/KAFKA-16107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16107. - Reviewer: David Jacot Resolution: Fixed > Ensure consumer does not start fetching f

[jira] [Created] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned

David Jacot created KAFKA-16194: --- Summary: KafkaConsumer.groupMetadata() should be correct when first records are returned Key: KAFKA-16194 URL: https://issues.apache.org/jira/browse/KAFKA-16194

[jira] [Resolved] (KAFKA-14505) Implement TnxOffsetCommit API

[ https://issues.apache.org/jira/browse/KAFKA-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14505. - Fix Version/s: 3.8.0 Resolution: Fixed > Implement TnxOffsetCommit

[jira] [Resolved] (KAFKA-16095) Update list group state type filter to include the states for the new consumer group type

[ https://issues.apache.org/jira/browse/KAFKA-16095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16095. - Fix Version/s: 3.8.0 Resolution: Fixed > Update list group state type filter to incl

[jira] [Resolved] (KAFKA-16168) Implement GroupCoordinator.onPartitionsDeleted

[ https://issues.apache.org/jira/browse/KAFKA-16168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16168. - Fix Version/s: 3.8.0 Resolution: Fixed > Implement GroupCoordinator.onPartitionsDele

[jira] [Resolved] (KAFKA-16189) Extend admin to support ConsumerGroupDescribe API

[ https://issues.apache.org/jira/browse/KAFKA-16189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16189. - Fix Version/s: 3.8.0 Resolution: Fixed > Extend admin to support ConsumerGroupDescr

[jira] [Resolved] (KAFKA-15460) Add group type filter to ListGroups API

[ https://issues.apache.org/jira/browse/KAFKA-15460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15460. - Fix Version/s: 3.8.0 Resolution: Fixed > Add group type filter to ListGroups

[jira] [Created] (KAFKA-16227) Console consumer fails with `IllegalStateException`

David Jacot created KAFKA-16227: --- Summary: Console consumer fails with `IllegalStateException` Key: KAFKA-16227 URL: https://issues.apache.org/jira/browse/KAFKA-16227 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-16178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16178. - Resolution: Fixed > AsyncKafkaConsumer doesn't retry joining the group after redis

[jira] [Created] (KAFKA-16244) Move code style exceptions from suppressions.xml to the code

David Jacot created KAFKA-16244: --- Summary: Move code style exceptions from suppressions.xml to the code Key: KAFKA-16244 URL: https://issues.apache.org/jira/browse/KAFKA-16244 Project: Kafka

[jira] [Created] (KAFKA-16249) Improve reconciliation state machine

David Jacot created KAFKA-16249: --- Summary: Improve reconciliation state machine Key: KAFKA-16249 URL: https://issues.apache.org/jira/browse/KAFKA-16249 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-16306) GroupCoordinatorService logger is not configured

[ https://issues.apache.org/jira/browse/KAFKA-16306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16306. - Fix Version/s: 3.8.0 Resolution: Fixed > GroupCoordinatorService logger is

[jira] [Resolved] (KAFKA-15462) Add group type filter to the admin client

[ https://issues.apache.org/jira/browse/KAFKA-15462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15462. - Fix Version/s: 3.8.0 Resolution: Fixed > Add group type filter to the admin cli

[jira] [Created] (KAFKA-16367) Full ConsumerGroupHeartbeat response must be sent when full request is received

David Jacot created KAFKA-16367: --- Summary: Full ConsumerGroupHeartbeat response must be sent when full request is received Key: KAFKA-16367 URL: https://issues.apache.org/jira/browse/KAFKA-16367

[jira] [Resolved] (KAFKA-16249) Improve reconciliation state machine

[ https://issues.apache.org/jira/browse/KAFKA-16249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16249. - Fix Version/s: 3.8.0 Resolution: Fixed > Improve reconciliation state mach

[jira] [Resolved] (KAFKA-15997) Ensure fairness in the uniform assignor

[ https://issues.apache.org/jira/browse/KAFKA-15997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15997. - Resolution: Fixed This issue got resolved by https://issues.apache.org/jira/browse/KAFKA-16249

[jira] [Created] (KAFKA-16374) High watermark updates should have a higher priority

David Jacot created KAFKA-16374: --- Summary: High watermark updates should have a higher priority Key: KAFKA-16374 URL: https://issues.apache.org/jira/browse/KAFKA-16374 Project: Kafka Issue

[jira] [Resolved] (KAFKA-16367) Full ConsumerGroupHeartbeat response must be sent when full request is received

[ https://issues.apache.org/jira/browse/KAFKA-16367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16367. - Fix Version/s: 3.8.0 Resolution: Fixed > Full ConsumerGroupHeartbeat response must

[jira] [Resolved] (KAFKA-16313) Offline group protocol migration

[ https://issues.apache.org/jira/browse/KAFKA-16313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16313. - Fix Version/s: 3.8.0 Assignee: Dongnuo Lyu Resolution: Fixed > Offline gr

[jira] [Resolved] (KAFKA-15763) Group Coordinator should not deliver new assignment before previous one is acknowledged

[ https://issues.apache.org/jira/browse/KAFKA-15763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15763. - Resolution: Won't Fix We went with another approach. > Group Coordinator should not

[jira] [Resolved] (KAFKA-15989) Upgrade existing generic group to consumer group

[ https://issues.apache.org/jira/browse/KAFKA-15989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15989. - Fix Version/s: 3.8.0 Resolution: Fixed > Upgrade existing generic group to consu

[jira] [Resolved] (KAFKA-16374) High watermark updates should have a higher priority

[ https://issues.apache.org/jira/browse/KAFKA-16374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16374. - Fix Version/s: 3.8.0 Resolution: Fixed > High watermark updates should have a hig

[jira] [Resolved] (KAFKA-16353) Offline protocol migration integration tests

[ https://issues.apache.org/jira/browse/KAFKA-16353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16353. - Resolution: Fixed > Offline protocol migration integration te

[jira] [Resolved] (KAFKA-16148) Implement GroupMetadataManager#onUnloaded

[ https://issues.apache.org/jira/browse/KAFKA-16148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16148. - Fix Version/s: 3.8.0 Resolution: Fixed > Implement GroupMetadataManager#onUnloa

[jira] [Created] (KAFKA-16470) kafka-dump-log --offsets-decoder should support new records

David Jacot created KAFKA-16470: --- Summary: kafka-dump-log --offsets-decoder should support new records Key: KAFKA-16470 URL: https://issues.apache.org/jira/browse/KAFKA-16470 Project: Kafka

[jira] [Created] (KAFKA-16503) getOrMaybeCreateClassicGroup should not thrown GroupIdNotFoundException

David Jacot created KAFKA-16503: --- Summary: getOrMaybeCreateClassicGroup should not thrown GroupIdNotFoundException Key: KAFKA-16503 URL: https://issues.apache.org/jira/browse/KAFKA-16503 Project: Kafka

[jira] [Resolved] (KAFKA-16294) Add group protocol migration enabling config

[ https://issues.apache.org/jira/browse/KAFKA-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16294. - Fix Version/s: 3.8.0 Resolution: Fixed > Add group protocol migration enabling con

<    3   4   5   6   7   8   9   10   11   12   >