Skip to content

feat: kafka-2pc#970

Draft
saksham-datazip wants to merge 5 commits into
stagingfrom
kafka/2pc
Draft

feat: kafka-2pc#970
saksham-datazip wants to merge 5 commits into
stagingfrom
kafka/2pc

Conversation

@saksham-datazip

Copy link
Copy Markdown
Collaborator

Description

Implemented support for Two-Phase Commit (2PC) in Kafka by persisting the topic name, partition, and offset information in the destination metadata. This enables reliable recovery and ensures Kafka consumption can resume from the last committed state.

Fixes # (issue)

Type of change

  • Bug fix (non-breaking change which fixes an issue)
  • New feature (non-breaking change which adds functionality)
  • Breaking change (fix or feature that would cause existing functionality to not work as expected)
  • This change requires a documentation update

How Has This Been Tested?

  • Ran sync and checked metadata.

Documentation

  • Documentation Link: [link to README, olake.io/docs, or olake-docs]
  • N/A (bug fix, refactor, or test changes only)

Related PR's (If Any):

@saksham-datazip saksham-datazip changed the title chore: pseudo-code feat: kafka-2pc Jun 7, 2026
@saksham-datazip saksham-datazip marked this pull request as draft June 12, 2026 10:49
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.

1 participant