Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

KNetCompactedReplicator enhancement #227

Conversation

masesdevelopers
Copy link
Contributor

Description

This PR adds:

  • Management of sync state
  • Delayed alignment
  • New enumerator
  • Management of parallel consumers based on partitions
  • Recover of partitions from previous generated topic

Related Issue

Closed #218

Motivation and Context

How Has This Been Tested?

Test available in the repo

Screenshots (if appropriate):

Types of changes

  • 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 change)

Checklist:

  • My code follows the code style of this project.
  • My change requires a change to the documentation.
  • I have updated the documentation accordingly.
  • I have read the CONTRIBUTING document.
  • I have added tests to cover my changes.
  • All new and existing tests passed.

@masesdevelopers masesdevelopers added enhancement New feature or request KNet KNet related issue labels Sep 2, 2023
@masesdevelopers masesdevelopers self-assigned this Sep 2, 2023
@masesdevelopers masesdevelopers merged commit 72ce025 into masesgroup:master Sep 2, 2023
6 checks passed
@masesdevelopers masesdevelopers deleted the 218-knetcompactedreplicator-shall-be-enhanced-to-cover-some-needs-of-kefcore branch September 2, 2023 01:46
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request KNet KNet related issue
Projects
None yet
Development

Successfully merging this pull request may close these issues.

KNetCompactedReplicator shall be enhanced to cover some needs of KEFCore
1 participant