[jira] [Created] (KAFKA-18756) Add share group configs to system tests

Chirag Wadhwa created KAFKA-18756: - Summary: Add share group configs to system tests Key: KAFKA-18756 URL: https://issues.apache.org/jira/browse/KAFKA-18756 Project: Kafka Issue Type: Sub-tas

[jira] [Created] (KAFKA-18745) Handle the disconnected inter broker RPC calls within the persister

Chirag Wadhwa created KAFKA-18745: - Summary: Handle the disconnected inter broker RPC calls within the persister Key: KAFKA-18745 URL: https://issues.apache.org/jira/browse/KAFKA-18745 Project: Kafka

[jira] [Resolved] (KAFKA-18642) Increase timeouts in share_consumer_test.py system tests

[ https://issues.apache.org/jira/browse/KAFKA-18642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Wadhwa resolved KAFKA-18642. --- Resolution: Fixed > Increase timeouts in share_consumer_test.py system tests > -

[jira] [Created] (KAFKA-18642) Increase timeouts in share_consumer_test.py system tests

Chirag Wadhwa created KAFKA-18642: - Summary: Increase timeouts in share_consumer_test.py system tests Key: KAFKA-18642 URL: https://issues.apache.org/jira/browse/KAFKA-18642 Project: Kafka Is

[jira] [Created] (KAFKA-18494) Initialize gaps in share partition cachedState to new available batches during share partition initialization

Chirag Wadhwa created KAFKA-18494: - Summary: Initialize gaps in share partition cachedState to new available batches during share partition initialization Key: KAFKA-18494 URL: https://issues.apache.org/jira/brows

[jira] [Created] (KAFKA-18397) Fix the scenario where acknowledgement callback is being called on null acknowledgements

Chirag Wadhwa created KAFKA-18397: - Summary: Fix the scenario where acknowledgement callback is being called on null acknowledgements Key: KAFKA-18397 URL: https://issues.apache.org/jira/browse/KAFKA-18397

[jira] [Resolved] (KAFKA-18312) Add "entityType": "topicName" to "SubscribedTopicNames" in ShareGroupHeartbeatRequest.json

[ https://issues.apache.org/jira/browse/KAFKA-18312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Wadhwa resolved KAFKA-18312. --- Resolution: Fixed The required PR has been merged > Add "entityType": "topicName" to "Subsc

[jira] [Created] (KAFKA-18312) Add "entityType": "topicName" to "SubscribedTopicNames" in ShareGroupHeartbeatRequest.json

Chirag Wadhwa created KAFKA-18312: - Summary: Add "entityType": "topicName" to "SubscribedTopicNames" in ShareGroupHeartbeatRequest.json Key: KAFKA-18312 URL: https://issues.apache.org/jira/browse/KAFKA-18312

[jira] [Created] (KAFKA-18164) Empty in memory acknowledgements when a shareAcknowledge request fails

Chirag Wadhwa created KAFKA-18164: - Summary: Empty in memory acknowledgements when a shareAcknowledge request fails Key: KAFKA-18164 URL: https://issues.apache.org/jira/browse/KAFKA-18164 Project: Kaf

[jira] [Created] (KAFKA-18165) Update nodesWithPendingRequests only when a request successfully builds

Chirag Wadhwa created KAFKA-18165: - Summary: Update nodesWithPendingRequests only when a request successfully builds Key: KAFKA-18165 URL: https://issues.apache.org/jira/browse/KAFKA-18165 Project: Ka

[jira] [Created] (KAFKA-17945) Use leader epoch while calling replicaManager.fetchOffsetForTimestamp in ShareFetchUtils

Chirag Wadhwa created KAFKA-17945: - Summary: Use leader epoch while calling replicaManager.fetchOffsetForTimestamp in ShareFetchUtils Key: KAFKA-17945 URL: https://issues.apache.org/jira/browse/KAFKA-17945

[jira] [Created] (KAFKA-17944) Add error handling in the cases when replicaManager.fetchOffsetForTimestamp throws an error

Chirag Wadhwa created KAFKA-17944: - Summary: Add error handling in the cases when replicaManager.fetchOffsetForTimestamp throws an error Key: KAFKA-17944 URL: https://issues.apache.org/jira/browse/KAFKA-17944

[jira] [Resolved] (KAFKA-17756) Add dynamic share group configurations group.share.heartbeat.interval.ms and group.share.session.timeout.ms

[ https://issues.apache.org/jira/browse/KAFKA-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Wadhwa resolved KAFKA-17756. --- Resolution: Fixed > Add dynamic share group configurations group.share.heartbeat.interval.ms

[jira] [Created] (KAFKA-17756) Add dynamic share group configurations group.share.heartbeat.interval.ms and group.share.session.timeout.ms

Chirag Wadhwa created KAFKA-17756: - Summary: Add dynamic share group configurations group.share.heartbeat.interval.ms and group.share.session.timeout.ms Key: KAFKA-17756 URL: https://issues.apache.org/jira/browse/

[jira] [Resolved] (KAFKA-16727) Add dynamic group configuration for record lock duration

[ https://issues.apache.org/jira/browse/KAFKA-16727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Wadhwa resolved KAFKA-16727. --- Resolution: Fixed > Add dynamic group configuration for record lock duration > -

[jira] [Resolved] (KAFKA-17532) Restructure Share Group Configs

[ https://issues.apache.org/jira/browse/KAFKA-17532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Wadhwa resolved KAFKA-17532. --- Resolution: Fixed > Restructure Share Group Configs > --- > >

[jira] [Created] (KAFKA-17532) Move ShareGroupConfig to share module

Chirag Wadhwa created KAFKA-17532: - Summary: Move ShareGroupConfig to share module Key: KAFKA-17532 URL: https://issues.apache.org/jira/browse/KAFKA-17532 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-17290) Add integration test for ShareGroupFetch/Acknowledge requests

[ https://issues.apache.org/jira/browse/KAFKA-17290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Wadhwa resolved KAFKA-17290. --- Resolution: Fixed The task has been completed and the PR has been merged > Add integration

[jira] [Resolved] (KAFKA-17127) Add check for whether the requested partition exists or not in Share Fetch request

[ https://issues.apache.org/jira/browse/KAFKA-17127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Wadhwa resolved KAFKA-17127. --- Resolution: Fixed > Add check for whether the requested partition exists or not in Share Fet

[jira] [Resolved] (KAFKA-17126) hande piggybacked acknowledgements asynchronously in Share Fetch and properly combine the results of fetch and acknowledge

[ https://issues.apache.org/jira/browse/KAFKA-17126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Wadhwa resolved KAFKA-17126. --- Resolution: Fixed > hande piggybacked acknowledgements asynchronously in Share Fetch and pro

[jira] [Resolved] (KAFKA-16750) Implement acknowledge API in SharePartitionManager

[ https://issues.apache.org/jira/browse/KAFKA-16750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Wadhwa resolved KAFKA-16750. --- Resolution: Fixed > Implement acknowledge API in SharePartitionManager > ---

[jira] [Created] (KAFKA-17127) Add check for whether the requested partition exists or not in Share Fetch request

Chirag Wadhwa created KAFKA-17127: - Summary: Add check for whether the requested partition exists or not in Share Fetch request Key: KAFKA-17127 URL: https://issues.apache.org/jira/browse/KAFKA-17127

[jira] [Created] (KAFKA-17126) hande piggybacked acknowledgements asynchronously in Share Fetch and properly combine the results of fetch and acknowledge

Chirag Wadhwa created KAFKA-17126: - Summary: hande piggybacked acknowledgements asynchronously in Share Fetch and properly combine the results of fetch and acknowledge Key: KAFKA-17126 URL: https://issues.apache.o