[jira] [Commented] (KAFKA-16728) Add dynamic group configuration for heartbeat interval and session timeout

[ https://issues.apache.org/jira/browse/KAFKA-16728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883143#comment-17883143 ] Lan Ding commented on KAFKA-16728: -- Hi [~schofielaj], are we ready to do this? I'm happ

[jira] [Assigned] (KAFKA-14772) Add ConsumerGroupHeartbeat API to AuthorizerIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-14772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding reassigned KAFKA-14772: Assignee: Lan Ding > Add ConsumerGroupHeartbeat API to AuthorizerIntegrationTest > --

[jira] [Commented] (KAFKA-14772) Add ConsumerGroupHeartbeat API to AuthorizerIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-14772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877563#comment-17877563 ] Lan Ding commented on KAFKA-14772: -- Hi [~dajac] , are we ready to do this? I'm happy to

[jira] [Commented] (KAFKA-17347) Add omitted --client-metrics option to kafka-configs.sh

[ https://issues.apache.org/jira/browse/KAFKA-17347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876874#comment-17876874 ] Lan Ding commented on KAFKA-17347: --  Hi [~schofielaj], I'm happy to take this one over.

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

Lan Ding created KAFKA-17327: Summary: Add support of group in kafka-configs.sh Key: KAFKA-17327 URL: https://issues.apache.org/jira/browse/KAFKA-17327 Project: Kafka Issue Type: Improvement

[jira] [Assigned] (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 ] Lan Ding reassigned KAFKA-14510: Assignee: Lan Ding (was: Jimmy Wang) > Extend DescribeConfigs API to support group configs > ---

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

[ https://issues.apache.org/jira/browse/KAFKA-14510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872044#comment-17872044 ] Lan Ding commented on KAFKA-14510: -- Hi [~jimmywang611], I'm happy to take this one over

[jira] [Assigned] (KAFKA-17018) Metadata version 3.9 should return Fetch version 17

[ https://issues.apache.org/jira/browse/KAFKA-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lan Ding reassigned KAFKA-17018: Assignee: Lan Ding > Metadata version 3.9 should return Fetch version 17 > --

[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&focusedCommentId=17805868#comment-17805868 ] Lan Ding commented on KAFKA-16095: -- [~rreddy22] I think the flag "–type" should be adde

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

[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&focusedCommentId=17801803#comment-17801803 ] Lan Ding commented on KAFKA-15777: -- hi [~ckamal],  could I pick this up? > Configurabl

[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&focusedCommentId=17800228#comment-17800228 ] Lan Ding commented on KAFKA-15089: -- hi [~dajac] , could I pick this up? > Consolidate

[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&focusedCommentId=17744384#comment-17744384 ] Lan Ding commented on KAFKA-15194: -- [~divijvaidya] Sorry, just saw the message, [~owen-

[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&focusedCommentId=17742602#comment-17742602 ] Lan Ding commented on KAFKA-15169: -- Sure, I will add tests for RemoteIndexCache in days

[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&focusedCommentId=17740596#comment-17740596 ] Lan Ding commented on KAFKA-15154: -- I think you said is correct, "metrics.values()" wil

[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&focusedCommentId=17740544#comment-17740544 ] Lan Ding commented on KAFKA-15153: -- Hi,  can I be assigned to it? > Use Python `is` in

[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&focusedCommentId=17739347#comment-17739347 ] Lan Ding commented on KAFKA-15140: -- Hi, I'm interested in this issue,  can I be assigne

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

[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