[jira] [Resolved] (KAFKA-17495) Factor out common setup from server-side assignor benchmarks

[ https://issues.apache.org/jira/browse/KAFKA-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17495. - Fix Version/s: 4.0.0 Resolution: Fixed > Factor out common setup from server-side assigno

[jira] [Created] (KAFKA-17571) Revert #17219

David Jacot created KAFKA-17571: --- Summary: Revert #17219 Key: KAFKA-17571 URL: https://issues.apache.org/jira/browse/KAFKA-17571 Project: Kafka Issue Type: Sub-task Affects Versions: 4.0.0

[jira] [Resolved] (KAFKA-17306) Soften the validation when replaying tombstones

[ https://issues.apache.org/jira/browse/KAFKA-17306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17306. - Fix Version/s: 4.0.0 Resolution: Fixed > Soften the validation when replaying tombstones

[jira] [Resolved] (KAFKA-15756) Migrate existing integration tests to run old protocol in new coordinator

[ https://issues.apache.org/jira/browse/KAFKA-15756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15756. - Resolution: Won't Do The new group coordinator is now used by default so all the tests use it by

[jira] [Resolved] (KAFKA-15621) Add histogram metrics to GroupCoordinatorRuntimeMetrics

[ https://issues.apache.org/jira/browse/KAFKA-15621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15621. - Fix Version/s: 4.0.0 Resolution: Fixed > Add histogram metrics to GroupCoordinatorRuntime

[jira] [Resolved] (KAFKA-17413) Re-introduce `group.version` feature flag

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

[jira] [Resolved] (KAFKA-17327) Add support of group in kafka-configs.sh

[ https://issues.apache.org/jira/browse/KAFKA-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17327. - Resolution: Fixed > Add support of group in kafka-configs.sh > -

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

[ https://issues.apache.org/jira/browse/KAFKA-17376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17376. - Resolution: Fixed > Use the new group coordinator by default in 4.0 > --

[jira] [Reopened] (KAFKA-14048) The Next Generation of the Consumer Rebalance Protocol

[ https://issues.apache.org/jira/browse/KAFKA-14048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot reopened KAFKA-14048: - > The Next Generation of the Consumer Rebalance Protocol > -

[jira] [Resolved] (KAFKA-14048) The Next Generation of the Consumer Rebalance Protocol

[ https://issues.apache.org/jira/browse/KAFKA-14048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14048. - Fix Version/s: 4.0.0 Resolution: Fixed > The Next Generation of the Consumer Rebalance Pr

[jira] [Created] (KAFKA-17413) Re-introduce `group.version` feature flag

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

[jira] [Resolved] (KAFKA-16379) Coordinator flush time and event purgatory time metrics

[ https://issues.apache.org/jira/browse/KAFKA-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16379. - Fix Version/s: 4.0.0 Resolution: Fixed > Coordinator flush time and event purgatory time

[jira] [Resolved] (KAFKA-17279) Handle retriable errors from offset fetches in ConsumerCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-17279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17279. - Fix Version/s: 3.9.0 Resolution: Fixed > Handle retriable errors from offset fetches in C

[jira] [Created] (KAFKA-17383) Update upgrade notes about removal of `offsets.commit.required.acks`

David Jacot created KAFKA-17383: --- Summary: Update upgrade notes about removal of `offsets.commit.required.acks` Key: KAFKA-17383 URL: https://issues.apache.org/jira/browse/KAFKA-17383 Project: Kafka

[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. > getOrMaybeCreateCl

[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: Sub

[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/1684

[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/1684

[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/1684

[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 group conf

[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 support gr

[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 member usi

[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 Resolutio

[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 R

[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-partition with stickin

[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-atomic

[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 with

[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 3.9 > -

[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 Ty

[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 share

[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 condition > --

[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 with ConsumerProtocol

[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 Report

[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 GroupCoordinatorRuntimeMetrics > --

[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. > Adjust classic

[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 ConsumerProtocolSubscription > ---

[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/ap

[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 batches >

[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 not > subs

[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 Proj

[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 metadata

[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 API >

[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 common >

[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(timeout) >

[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 the size is

[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 Assignor

[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 flag > ---

[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 interface > -

[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 Format Change > --- > >

[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 ConsumerGroup > ---

[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-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: F

[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: K

[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 Lookup Pa

[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 > CoordinatorRuntim

[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 > Handle FencedInst

[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 in ass

[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 API for

[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 API for

[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-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 temporarily

[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 Coordinator > -

[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 the correct

[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 3.8 >

[jira] [Created] (KAFKA-16736) Remove offsets.commit.required.acks in 4.0

David Jacot created KAFKA-16736: --- Summary: Remove offsets.commit.required.acks in 4.0 Key: KAFKA-16736 URL: https://issues.apache.org/jira/browse/KAFKA-16736 Project: Kafka Issue Type: Sub-task

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

David Jacot created KAFKA-16735: --- Summary: Deprecate offsets.commit.required.acks in 3.8 Key: KAFKA-16735 URL: https://issues.apache.org/jira/browse/KAFKA-16735 Project: Kafka Issue Type: Sub-t

[jira] [Resolved] (KAFKA-16587) Store subscription model for consumer group in group state

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

[jira] [Resolved] (KAFKA-16663) CoordinatorRuntime write timer tasks should be cancelled once HWM advances

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

[jira] [Resolved] (KAFKA-16307) fix EventAccumulator thread idle ratio metric

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

[jira] [Resolved] (KAFKA-16615) JoinGroup API for upgrading ConsumerGroup

[ https://issues.apache.org/jira/browse/KAFKA-16615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16615. - Fix Version/s: 3.8.0 Reviewer: David Jacot Assignee: Dongnuo Lyu Resolut

[jira] [Created] (KAFKA-16658) Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8)

David Jacot created KAFKA-16658: --- Summary: Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8) Key: KAFKA-16658 URL: https://issues.apache.org/jira/browse/KAFKA-16658 Project: Kafka

[jira] [Resolved] (KAFKA-16568) Add JMH Benchmarks for assignor performance testing

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

[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 config > -

[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] [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 Is

[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#onUnloaded >

[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 tests > -

[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 higher prio

[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 consumer group

[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 deliver new

[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 group pro

[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 be sen

[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 Type

[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] [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 machine > -

[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 Project

[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 client >

[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 not configured

[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] [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 I

[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 rediscovering group

[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-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 API > --

[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 ConsumerGroupDescribe AP

[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.onPartitionsDeleted >

[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 include t

[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 API >

[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 Project

[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 from add

[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: S

  1   2   3   4   5   >