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:
[
https://issues.apache.org/jira/browse/KAFKA-16832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-16832:
---
Assignee: Dongnuo Lyu
> LeaveGroup 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
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
[
https://issues.apache.org/jira/browse/KAFKA-16762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-16762:
---
Assignee: Dongnuo Lyu
> SyncGroup API for upgrading ConsumerGroup
>
[
https://issues.apache.org/jira/browse/KAFKA-16673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-16673:
---
Assignee: Dongnuo Lyu
> Optimize toTopicPartitions with ConsumerProtocolSubscription
>
[
https://issues.apache.org/jira/browse/KAFKA-16674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-16674:
---
Assignee: Dongnuo Lyu
> 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
Dongnuo Lyu created KAFKA-16673:
---
Summary: Optimize toTopicPartitions with
ConsumerProtocolSubscription
Key: KAFKA-16673
URL: https://issues.apache.org/jira/browse/KAFKA-16673
Project: Kafka
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu updated KAFKA-16294:
Description:
The online upgrade is triggered when a consumer group heartbeat request is
received
[
https://issues.apache.org/jira/browse/KAFKA-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu updated KAFKA-16294:
Description:
The online upgrade is triggered when a consumer group heartbeat request is
received
[
https://issues.apache.org/jira/browse/KAFKA-15756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu updated KAFKA-15756:
Description:
There is one flaky test left, we need to figure out how to reduce the flakiness.
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:
[
https://issues.apache.org/jira/browse/KAFKA-16313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu updated KAFKA-16313:
Summary: Offline group protocol migration (was: Offline group protocol
upgrade)
> Offline group
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
[
https://issues.apache.org/jira/browse/KAFKA-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu updated KAFKA-16294:
Description:
The offline upgrade is triggered when a consumer group heartbeat request is
[
https://issues.apache.org/jira/browse/KAFKA-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-16294:
---
Assignee: Dongnuo Lyu
> 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:
[
https://issues.apache.org/jira/browse/KAFKA-16178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu updated KAFKA-16178:
Description:
{code:java}
[2024-01-17 21:34:59,500] INFO [Consumer
[
https://issues.apache.org/jira/browse/KAFKA-16178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu updated KAFKA-16178:
Description:
{code:java}
[2024-01-17 21:34:59,500] INFO [Consumer
[
https://issues.apache.org/jira/browse/KAFKA-16178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu updated KAFKA-16178:
Description:
[2024-01-17 21:34:59,500] INFO [Consumer
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
[
https://issues.apache.org/jira/browse/KAFKA-15856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-15856:
---
Assignee: Dongnuo Lyu
> 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
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
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:
[
https://issues.apache.org/jira/browse/KAFKA-15756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-15756:
---
Assignee: Dongnuo Lyu
> Migrate existing integration tests to run old protocol in new
[
https://issues.apache.org/jira/browse/KAFKA-15705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu reassigned KAFKA-15705:
---
Assignee: Dongnuo Lyu
> 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
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
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
34 matches
Mail list logo