[jira] [Resolved] (KAFKA-18205) Refactor share coordinator and related classes for better readability and organization

2025-08-04 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-18205. - Resolution: Fixed This was a placeholder and the coordinator is in better shape over mul

[jira] [Created] (KAFKA-19483) Fix flaky test RemoteIndexCacheTest.testConcurrentCacheDeletedFileExists()

2025-07-08 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19483: --- Summary: Fix flaky test RemoteIndexCacheTest.testConcurrentCacheDeletedFileExists() Key: KAFKA-19483 URL: https://issues.apache.org/jira/browse/KAFKA-19483 Proj

[jira] [Created] (KAFKA-19482) Fix flaky test KafkaStreamsTelemetryIntegrationTest.shouldPassMetrics

2025-07-08 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19482: --- Summary: Fix flaky test KafkaStreamsTelemetryIntegrationTest.shouldPassMetrics Key: KAFKA-19482 URL: https://issues.apache.org/jira/browse/KAFKA-19482 Project:

[jira] [Created] (KAFKA-19481) Fix flaky test AuthorizerIntegrationTest.testConsumerGroupHeartbeatWithRegex()

2025-07-08 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19481: --- Summary: Fix flaky test AuthorizerIntegrationTest.testConsumerGroupHeartbeatWithRegex() Key: KAFKA-19481 URL: https://issues.apache.org/jira/browse/KAFKA-19481

[jira] [Resolved] (KAFKA-19456) State and leader epoch should only be used for validation and not be updated in share coordinator write state RPC.

2025-07-04 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-19456. - Fix Version/s: 4.2.0 Resolution: Fixed > State and leader epoch should only be us

[jira] [Resolved] (KAFKA-19454) Share group delete should be resilient to metadata image issues in group coordinator.

2025-07-04 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-19454. - Fix Version/s: 4.2.0 Resolution: Fixed > Share group delete should be resilient t

[jira] [Resolved] (KAFKA-19455) Make unknown_topic_or_partition error retriable by the persister state manager.

2025-07-04 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-19455. - Fix Version/s: 4.2.0 Resolution: Fixed > Make unknown_topic_or_partition error re

[jira] [Created] (KAFKA-19457) Revisit the threshold to retry initialize share state RPC in group coordinator.

2025-06-30 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19457: --- Summary: Revisit the threshold to retry initialize share state RPC in group coordinator. Key: KAFKA-19457 URL: https://issues.apache.org/jira/browse/KAFKA-19457

[jira] [Created] (KAFKA-19456) State epoch should only be used for validation and not be updated in share coordinator write state RPC.

2025-06-30 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19456: --- Summary: State epoch should only be used for validation and not be updated in share coordinator write state RPC. Key: KAFKA-19456 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (KAFKA-19454) Share group delete should be resilient to metadata image issues in group coordinator.

2025-06-30 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19454: --- Summary: Share group delete should be resilient to metadata image issues in group coordinator. Key: KAFKA-19454 URL: https://issues.apache.org/jira/browse/KAFKA-19454

[jira] [Created] (KAFKA-19455) Make unknown_topic_or_partition error retriable by the persister state manager.

2025-06-30 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19455: --- Summary: Make unknown_topic_or_partition error retriable by the persister state manager. Key: KAFKA-19455 URL: https://issues.apache.org/jira/browse/KAFKA-19455

[jira] [Created] (KAFKA-19453) Handle ShareGroupStatePartitionMetadata replay in group coordinator for non-existent groups.

2025-06-30 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19453: --- Summary: Handle ShareGroupStatePartitionMetadata replay in group coordinator for non-existent groups. Key: KAFKA-19453 URL: https://issues.apache.org/jira/browse/KAFKA-19453

[jira] [Created] (KAFKA-19344) Move assignable share partition method from describer to group spec.

2025-05-27 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19344: --- Summary: Move assignable share partition method from describer to group spec. Key: KAFKA-19344 URL: https://issues.apache.org/jira/browse/KAFKA-19344 Project: K

[jira] [Created] (KAFKA-19337) Bug in ShareCoordinatorShard.generateShareStateRecord prevents stateEpoch update misses.

2025-05-27 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19337: --- Summary: Bug in ShareCoordinatorShard.generateShareStateRecord prevents stateEpoch update misses. Key: KAFKA-19337 URL: https://issues.apache.org/jira/browse/KAFKA-19337

[jira] [Created] (KAFKA-19338) Share coordinator read state and write state should return error, if the share partition is not initialized.

2025-05-27 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19338: --- Summary: Share coordinator read state and write state should return error, if the share partition is not initialized. Key: KAFKA-19338 URL: https://issues.apache.org/jira/br

[jira] [Resolved] (KAFKA-19143) Setup periodic job to clean share group deleting metadata state in GC

2025-05-14 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-19143. - Resolution: Not A Problem > Setup periodic job to clean share group deleting metadata st

[jira] [Created] (KAFKA-19281) Add metadata version check to enable share coordinator timer tasks.

2025-05-14 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19281: --- Summary: Add metadata version check to enable share coordinator timer tasks. Key: KAFKA-19281 URL: https://issues.apache.org/jira/browse/KAFKA-19281 Project: Ka

[jira] [Created] (KAFKA-19143) Setup periodic job to clean share group deleting metadata state in GC

2025-04-15 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19143: --- Summary: Setup periodic job to clean share group deleting metadata state in GC Key: KAFKA-19143 URL: https://issues.apache.org/jira/browse/KAFKA-19143 Project:

[jira] [Created] (KAFKA-19115) Utilize initiazed topics info to verify delete share group offsets

2025-04-09 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-19115: --- Summary: Utilize initiazed topics info to verify delete share group offsets Key: KAFKA-19115 URL: https://issues.apache.org/jira/browse/KAFKA-19115 Project: Kaf

[jira] [Resolved] (KAFKA-18827) Initialize share group state impl

2025-04-03 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-18827. - Resolution: Fixed > Initialize share group state impl >

[jira] [Resolved] (KAFKA-16719) Add AdminClient.deleteShareGroups

2025-03-20 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-16719. - Resolution: Fixed > Add AdminClient.deleteShareGroups >

[jira] [Created] (KAFKA-18879) Formatter for share group specific records in __consumer_offsets

2025-02-26 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18879: --- Summary: Formatter for share group specific records in __consumer_offsets Key: KAFKA-18879 URL: https://issues.apache.org/jira/browse/KAFKA-18879 Project: Kafka

[jira] [Created] (KAFKA-18828) Update share group metrics code in group coordinator

2025-02-18 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18828: --- Summary: Update share group metrics code in group coordinator Key: KAFKA-18828 URL: https://issues.apache.org/jira/browse/KAFKA-18828 Project: Kafka Is

[jira] [Created] (KAFKA-18827) Initialize share group state impl

2025-02-18 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18827: --- Summary: Initialize share group state impl Key: KAFKA-18827 URL: https://issues.apache.org/jira/browse/KAFKA-18827 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18747) Persister request de-duplication

2025-02-06 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18747: --- Summary: Persister request de-duplication Key: KAFKA-18747 URL: https://issues.apache.org/jira/browse/KAFKA-18747 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18665) Controller quorum error when initializing cluster instance

2025-01-29 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18665: --- Summary: Controller quorum error when initializing cluster instance Key: KAFKA-18665 URL: https://issues.apache.org/jira/browse/KAFKA-18665 Project: Kafka

[jira] [Created] (KAFKA-18632) ShareConsumerTest multibroker tests

2025-01-23 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18632: --- Summary: ShareConsumerTest multibroker tests Key: KAFKA-18632 URL: https://issues.apache.org/jira/browse/KAFKA-18632 Project: Kafka Issue Type: Sub-tas

[jira] [Created] (KAFKA-18629) DeleteShareGroups impl

2025-01-23 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18629: --- Summary: DeleteShareGroups impl Key: KAFKA-18629 URL: https://issues.apache.org/jira/browse/KAFKA-18629 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-18551) Flaky test - EagerConsumerCoordinatorTest > testOutdatedCoordinatorAssignment()

2025-01-15 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-18551. - Resolution: Duplicate https://issues.apache.org/jira/browse/KAFKA-15900 > Flaky test -

[jira] [Resolved] (KAFKA-18550) Flaky test - KafkaAdminClientTest > testAdminClientApisAuthenticationFailure() in trunk

2025-01-15 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-18550. - Resolution: Duplicate https://issues.apache.org/jira/browse/KAFKA-18441 > Flaky test -

[jira] [Created] (KAFKA-18551) Flaky test - EagerConsumerCoordinatorTest > testOutdatedCoordinatorAssignment()

2025-01-15 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18551: --- Summary: Flaky test - EagerConsumerCoordinatorTest > testOutdatedCoordinatorAssignment() Key: KAFKA-18551 URL: https://issues.apache.org/jira/browse/KAFKA-18551

[jira] [Created] (KAFKA-18550) Flaky test - KafkaAdminClientTest > testAdminClientApisAuthenticationFailure() in trunk

2025-01-15 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18550: --- Summary: Flaky test - KafkaAdminClientTest > testAdminClientApisAuthenticationFailure() in trunk Key: KAFKA-18550 URL: https://issues.apache.org/jira/browse/KAFKA-18550

[jira] [Created] (KAFKA-18513) Add record count validation for share group state topic to ShareConsumerTest

2025-01-14 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18513: --- Summary: Add record count validation for share group state topic to ShareConsumerTest Key: KAFKA-18513 URL: https://issues.apache.org/jira/browse/KAFKA-18513 Pr

[jira] [Created] (KAFKA-18232) Prune share state topic metrics

2024-12-13 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18232: --- Summary: Prune share state topic metrics Key: KAFKA-18232 URL: https://issues.apache.org/jira/browse/KAFKA-18232 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18205) Refactor share coordinator and related classes for better readability and organization

2024-12-11 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18205: --- Summary: Refactor share coordinator and related classes for better readability and organization Key: KAFKA-18205 URL: https://issues.apache.org/jira/browse/KAFKA-18205

[jira] [Resolved] (KAFKA-18057) Algorithm to calculate redundant interval of offsets for cleanup

2024-12-11 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-18057. - Resolution: Won't Fix This is addressed in a single PR for issue KAFKA-18058 > Algorith

[jira] [Created] (KAFKA-18170) Periodic snapshots for cold share partitions

2024-12-06 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18170: --- Summary: Periodic snapshots for cold share partitions Key: KAFKA-18170 URL: https://issues.apache.org/jira/browse/KAFKA-18170 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18058) Integrate offset cleanup algorithm with share coordinator

2024-11-21 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18058: --- Summary: Integrate offset cleanup algorithm with share coordinator Key: KAFKA-18058 URL: https://issues.apache.org/jira/browse/KAFKA-18058 Project: Kafka

[jira] [Created] (KAFKA-18057) Algorithm to calculate redundant interval of offsets for cleanup

2024-11-21 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-18057: --- Summary: Algorithm to calculate redundant interval of offsets for cleanup Key: KAFKA-18057 URL: https://issues.apache.org/jira/browse/KAFKA-18057 Project: Kafka

[jira] [Resolved] (KAFKA-17991) Timed calls to future.get in DefaultStatePersister and test improvements

2024-11-14 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-17991. - Resolution: Fixed > Timed calls to future.get in DefaultStatePersister and test improvem

[jira] [Created] (KAFKA-17991) Timed calls to future.get in DefaultStatePersister and test improvements

2024-11-12 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-17991: --- Summary: Timed calls to future.get in DefaultStatePersister and test improvements Key: KAFKA-17991 URL: https://issues.apache.org/jira/browse/KAFKA-17991 Projec

[jira] [Created] (KAFKA-17796) Add support persist higher leaderEpoch in read state call in share coordinator.

2024-10-15 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-17796: --- Summary: Add support persist higher leaderEpoch in read state call in share coordinator. Key: KAFKA-17796 URL: https://issues.apache.org/jira/browse/KAFKA-17796

[jira] [Resolved] (KAFKA-17633) Implement formatter for share group state topic records

2024-10-15 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-17633. - Resolution: Fixed > Implement formatter for share group state topic records > --

[jira] [Resolved] (KAFKA-17367) Add share coordinator implementation

2024-10-15 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-17367. - Resolution: Fixed > Add share coordinator implementation > -

[jira] [Resolved] (KAFKA-17469) Move appropriate classes and interfaces to the new share module

2024-10-03 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-17469. - Resolution: Fixed > Move appropriate classes and interfaces to the new share module > --

[jira] [Reopened] (KAFKA-17469) Move appropriate classes and interfaces to the new share module

2024-10-02 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan reopened KAFKA-17469: - need to move the classes to separate package > Move appropriate classes and interfaces to t

[jira] [Created] (KAFKA-17633) Implement formatter for share group state topic records

2024-09-27 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-17633: --- Summary: Implement formatter for share group state topic records Key: KAFKA-17633 URL: https://issues.apache.org/jira/browse/KAFKA-17633 Project: Kafka

[jira] [Resolved] (KAFKA-17469) Move appropriate classes and interfaces to the new share module

2024-09-25 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-17469. - Resolution: Fixed > Move appropriate classes and interfaces to the new share module > --

[jira] [Created] (KAFKA-17469) Move appropriate classes and interfaces to the new share module

2024-09-03 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-17469: --- Summary: Move appropriate classes and interfaces to the new share module Key: KAFKA-17469 URL: https://issues.apache.org/jira/browse/KAFKA-17469 Project: Kafka

[jira] [Created] (KAFKA-17367) Add share coordinator implementation

2024-08-19 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-17367: --- Summary: Add share coordinator implementation Key: KAFKA-17367 URL: https://issues.apache.org/jira/browse/KAFKA-17367 Project: Kafka Issue Type: Sub-ta

[jira] [Resolved] (KAFKA-17330) Introduce share-coordinator module and add resources

2024-08-19 Thread Sushant Mahajan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sushant Mahajan resolved KAFKA-17330. - Resolution: Fixed > Introduce share-coordinator module and add resources > -

[jira] [Created] (KAFKA-17342) Move common coordinator code from group-coordinator into separate module coordinator-common

2024-08-14 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-17342: --- Summary: Move common coordinator code from group-coordinator into separate module coordinator-common Key: KAFKA-17342 URL: https://issues.apache.org/jira/browse/KAFKA-17342

[jira] [Created] (KAFKA-17330) Introduce share-coordinator module

2024-08-13 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-17330: --- Summary: Introduce share-coordinator module Key: KAFKA-17330 URL: https://issues.apache.org/jira/browse/KAFKA-17330 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-17329) Implement DefaultShareStatePersister

2024-08-13 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-17329: --- Summary: Implement DefaultShareStatePersister Key: KAFKA-17329 URL: https://issues.apache.org/jira/browse/KAFKA-17329 Project: Kafka Issue Type: Sub-ta

[jira] [Created] (KAFKA-15077) FileTokenRetriever does trim the token before returning it.

2023-06-09 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-15077: --- Summary: FileTokenRetriever does trim the token before returning it. Key: KAFKA-15077 URL: https://issues.apache.org/jira/browse/KAFKA-15077 Project: Kafka

[jira] [Created] (KAFKA-14212) Fetch error response when hitting public OAuth/OIDC provider

2022-09-09 Thread Sushant Mahajan (Jira)
Sushant Mahajan created KAFKA-14212: --- Summary: Fetch error response when hitting public OAuth/OIDC provider Key: KAFKA-14212 URL: https://issues.apache.org/jira/browse/KAFKA-14212 Project: Kafka