[jira] [Created] (KAFKA-16832) LeaveGroup API for upgrading ConsumerGroup
Dongnuo Lyu created KAFKA-16832: --- Summary: LeaveGroup API for upgrading ConsumerGroup Key: KAFKA-16832 URL: https://issues.apache.org/jira/browse/KAFKA-16832 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16793) Heartbeat API for upgrading ConsumerGroup
Dongnuo Lyu created KAFKA-16793: --- Summary: Heartbeat API for upgrading ConsumerGroup Key: KAFKA-16793 URL: https://issues.apache.org/jira/browse/KAFKA-16793 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu Assignee: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16762) SyncGroup API for upgrading ConsumerGroup
Dongnuo Lyu created KAFKA-16762: --- Summary: SyncGroup API for upgrading ConsumerGroup Key: KAFKA-16762 URL: https://issues.apache.org/jira/browse/KAFKA-16762 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16674) Adjust classicGroupJoinToConsumerGroup to add subscription model
Dongnuo Lyu created KAFKA-16674: --- Summary: Adjust classicGroupJoinToConsumerGroup to add subscription model Key: KAFKA-16674 URL: https://issues.apache.org/jira/browse/KAFKA-16674 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu [https://github.com/apache/kafka/pull/15785] adds subscription model to the group state that affects `classicGroupJoinToConsumerGroup`. We'll need to make adjustment to comply with the change once #15785 is merged. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16673) Optimize toTopicPartitions with ConsumerProtocolSubscription
Dongnuo Lyu created KAFKA-16673: --- Summary: Optimize toTopicPartitions with ConsumerProtocolSubscription Key: KAFKA-16673 URL: https://issues.apache.org/jira/browse/KAFKA-16673 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu https://github.com/apache/kafka/pull/15798#discussion_r1582981154 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16615) JoinGroup API for upgrading ConsumerGroup
Dongnuo Lyu created KAFKA-16615: --- Summary: JoinGroup API for upgrading ConsumerGroup Key: KAFKA-16615 URL: https://issues.apache.org/jira/browse/KAFKA-16615 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16554) Online downgrade triggering and group type conversion
Dongnuo Lyu created KAFKA-16554: --- Summary: Online downgrade triggering and group type conversion Key: KAFKA-16554 URL: https://issues.apache.org/jira/browse/KAFKA-16554 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16436) Online upgrade triggering and group type conversion
Dongnuo Lyu created KAFKA-16436: --- Summary: Online upgrade triggering and group type conversion Key: KAFKA-16436 URL: https://issues.apache.org/jira/browse/KAFKA-16436 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16353) Offline protocol migration integration tests
Dongnuo Lyu created KAFKA-16353: --- Summary: Offline protocol migration integration tests Key: KAFKA-16353 URL: https://issues.apache.org/jira/browse/KAFKA-16353 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu Assignee: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16313) Offline group protocol upgrade
Dongnuo Lyu created KAFKA-16313: --- Summary: Offline group protocol upgrade Key: KAFKA-16313 URL: https://issues.apache.org/jira/browse/KAFKA-16313 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16294) Add group protocol migration enabling config
Dongnuo Lyu created KAFKA-16294: --- Summary: Add group protocol migration enabling config Key: KAFKA-16294 URL: https://issues.apache.org/jira/browse/KAFKA-16294 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator
Dongnuo Lyu created KAFKA-16178: --- Summary: AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator Key: KAFKA-16178 URL: https://issues.apache.org/jira/browse/KAFKA-16178 Project: Kafka Issue Type: Bug Components: clients, consumer Reporter: Dongnuo Lyu Attachments: pkc-devc63jwnj_jan19_0_debug Some of the consumers don't consume any message. The logs show that after the consumer starts up and successfully logs in, # The consumer discovers the group coordinator. # The heartbeat to join group fails because "This is not the correct coordinator" # The consumer rediscover the group coordinator. Another heartbeat should follow the rediscovery of the group coordinator but there's no logs showing sign of a heartbeat request. On the server side, there is completely no log about the group id. A suspicion is that the consumer doesn't send a heartbeat request after rediscover the group coordinator. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15856) Add integration tests for JoinGroup API and SyncGroup API
Dongnuo Lyu created KAFKA-15856: --- Summary: Add integration tests for JoinGroup API and SyncGroup API Key: KAFKA-15856 URL: https://issues.apache.org/jira/browse/KAFKA-15856 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15849) Fix ListGroups API when runtime partition size is zero
Dongnuo Lyu created KAFKA-15849: --- Summary: Fix ListGroups API when runtime partition size is zero Key: KAFKA-15849 URL: https://issues.apache.org/jira/browse/KAFKA-15849 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu Assignee: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15756) Migrate existing integration tests to run old protocol in new coordinator
Dongnuo Lyu created KAFKA-15756: --- Summary: Migrate existing integration tests to run old protocol in new coordinator Key: KAFKA-15756 URL: https://issues.apache.org/jira/browse/KAFKA-15756 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15705) Add integration tests for Heartbeat API and GroupLeave API
Dongnuo Lyu created KAFKA-15705: --- Summary: Add integration tests for Heartbeat API and GroupLeave API Key: KAFKA-15705 URL: https://issues.apache.org/jira/browse/KAFKA-15705 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15647) Fix the different behavior in error handling between the old and new group coordinator
Dongnuo Lyu created KAFKA-15647: --- Summary: Fix the different behavior in error handling between the old and new group coordinator Key: KAFKA-15647 URL: https://issues.apache.org/jira/browse/KAFKA-15647 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu Assignee: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (KAFKA-15598) Add integration tests for DescribeGroups API, DeleteGroups API and OffsetDelete API
Dongnuo Lyu created KAFKA-15598: --- Summary: Add integration tests for DescribeGroups API, DeleteGroups API and OffsetDelete API Key: KAFKA-15598 URL: https://issues.apache.org/jira/browse/KAFKA-15598 Project: Kafka Issue Type: Sub-task Reporter: Dongnuo Lyu Assignee: Dongnuo Lyu -- This message was sent by Atlassian Jira (v8.20.10#820010)
