[jira] [Updated] (KAFKA-14920) Address timeouts and out of order sequences

[ https://issues.apache.org/jira/browse/KAFKA-14920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding updated KAFKA-14920: - Description: KAFKA-14844 showed the destructive nature of a timeout on the first produce request for a

[jira] [Commented] (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:comment-tabpanel=17805868#comment-17805868 ] Lan Ding commented on KAFKA-16095: -- [~rreddy22] I think the flag "–type" should be added to allow

[jira] [Assigned] (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 ] Lan Ding reassigned KAFKA-16095: Assignee: Lan Ding > Update list group state type filter to include the states for the new >

[jira] [Commented] (KAFKA-15777) Configurable remote fetch bytes per partition from Consumer

[ https://issues.apache.org/jira/browse/KAFKA-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801803#comment-17801803 ] Lan Ding commented on KAFKA-15777: -- hi [~ckamal],  could I pick this up? > Configurable remote fetch

[jira] [Assigned] (KAFKA-15206) Flaky test RemoteIndexCacheTest.testClose()

[ https://issues.apache.org/jira/browse/KAFKA-15206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding reassigned KAFKA-15206: Assignee: Lan Ding > Flaky test RemoteIndexCacheTest.testClose() >

[jira] [Commented] (KAFKA-15089) Consolidate all the group coordinator configs

[ https://issues.apache.org/jira/browse/KAFKA-15089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800228#comment-17800228 ] Lan Ding commented on KAFKA-15089: -- hi [~dajac] , could I pick this up? > Consolidate all the group

[jira] [Assigned] (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 ] Lan Ding reassigned KAFKA-14511: Assignee: Lan Ding > Extend AlterIncrementalConfigs API to support group config >

[jira] [Assigned] (KAFKA-15866) Refactor OffsetFetchRequestState Error handling to be more consistent with OffsetCommitRequestState

[ https://issues.apache.org/jira/browse/KAFKA-15866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding reassigned KAFKA-15866: Assignee: Lan Ding > Refactor OffsetFetchRequestState Error handling to be more consistent with

[jira] [Commented] (KAFKA-15194) Rename local tiered storage segment with offset as prefix for easy navigation

[ https://issues.apache.org/jira/browse/KAFKA-15194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744384#comment-17744384 ] Lan Ding commented on KAFKA-15194: -- [~divijvaidya] Sorry, just saw the message, [~owen-leung] has

[jira] [Commented] (KAFKA-15169) Add tests for RemoteIndexCache

[ https://issues.apache.org/jira/browse/KAFKA-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742602#comment-17742602 ] Lan Ding commented on KAFKA-15169: -- Sure, I will add tests for RemoteIndexCache in days. > Add tests

[jira] [Assigned] (KAFKA-15169) Add tests for RemoteIndexCache

[ https://issues.apache.org/jira/browse/KAFKA-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding reassigned KAFKA-15169: Assignee: Lan Ding > Add tests for RemoteIndexCache > -- > >

[jira] [Assigned] (KAFKA-15157) Print startup time for RemoteIndexCache

[ https://issues.apache.org/jira/browse/KAFKA-15157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding reassigned KAFKA-15157: Assignee: Lan Ding > Print startup time for RemoteIndexCache >

[jira] [Assigned] (KAFKA-15154) Potential bug: We don't acquire lock when reading checkQuotas

[ https://issues.apache.org/jira/browse/KAFKA-15154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding reassigned KAFKA-15154: Assignee: Lan Ding > Potential bug: We don't acquire lock when reading checkQuotas >

[jira] [Commented] (KAFKA-15154) Potential bug: We don't acquire lock when reading checkQuotas

[ https://issues.apache.org/jira/browse/KAFKA-15154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740596#comment-17740596 ] Lan Ding commented on KAFKA-15154: -- I think you said is correct, "metrics.values()" will returns a

[jira] [Assigned] (KAFKA-15153) Use Python `is` instead of `==` to compare for None

[ https://issues.apache.org/jira/browse/KAFKA-15153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding reassigned KAFKA-15153: Assignee: Lan Ding > Use Python `is` instead of `==` to compare for None >

[jira] [Commented] (KAFKA-15153) Use Python `is` instead of `==` to compare for None

[ https://issues.apache.org/jira/browse/KAFKA-15153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740544#comment-17740544 ] Lan Ding commented on KAFKA-15153: -- Hi,  can I be assigned to it? > Use Python `is` instead of `==`

[jira] [Commented] (KAFKA-15140) Improve TopicCommandIntegrationTest to be less flaky

[ https://issues.apache.org/jira/browse/KAFKA-15140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739347#comment-17739347 ] Lan Ding commented on KAFKA-15140: -- Hi, I'm interested in this issue,  can I be assigned to it? >

[jira] [Updated] (KAFKA-15130) Delete remote segments when delete a topic

[ https://issues.apache.org/jira/browse/KAFKA-15130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding updated KAFKA-15130: - Description: When tiered storage is enabled and {{delete.topic.enable=true}} , deleting a topic should

[jira] [Created] (KAFKA-15130) Delete remote segments when delete a topic

Lan Ding created KAFKA-15130: Summary: Delete remote segments when delete a topic Key: KAFKA-15130 URL: https://issues.apache.org/jira/browse/KAFKA-15130 Project: Kafka Issue Type: Improvement