Skip to content

Conversation

@PratRanj07
Copy link
Contributor

This PR intends to:

  • Segregate the acquired records based on the records and the AcquiredRecords array
  • Implement basic implicit acknowledgement(Accept/Gap)
  • Add tests to ensure we are consuming all the messages in one batch only that we get with a ShareFetch response

@PratRanj07 PratRanj07 requested a review from a team as a code owner December 2, 2025 08:48
@confluent-cla-assistant
Copy link

🎉 All Contributor License Agreements have been signed. Ready to merge.
Please push an empty commit if you would like to re-run the checks to verify CLA status for all contributors.

@PratRanj07 PratRanj07 changed the title Dev kip 932 segregate acquired records [KIP-932]: segregate acquired records Dec 2, 2025
@airlock-confluentinc airlock-confluentinc bot force-pushed the dev_kip-932_share-session-management branch from 6c6d281 to 19f1b8d Compare December 12, 2025 14:08
@airlock-confluentinc airlock-confluentinc bot force-pushed the dev_kip-932_segregate_acquired_records branch 2 times, most recently from ddfb47a to 29f9770 Compare December 14, 2025 21:32
@airlock-confluentinc airlock-confluentinc bot force-pushed the dev_kip-932_share-session-management branch 2 times, most recently from f2dafb6 to 9a06771 Compare January 9, 2026 00:26
Base automatically changed from dev_kip-932_share-session-management to dev_kip-932_queues-for-kafka January 9, 2026 07:42
@airlock-confluentinc airlock-confluentinc bot force-pushed the dev_kip-932_segregate_acquired_records branch from 29f9770 to f514e21 Compare January 12, 2026 10:56
@PratRanj07 PratRanj07 changed the base branch from dev_kip-932_queues-for-kafka to dev_kip-932_timer_bug_resolve January 12, 2026 10:56
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants