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

Controller #155

Merged
merged 42 commits into from
Jun 26, 2024
Merged

Controller #155

merged 42 commits into from
Jun 26, 2024

Conversation

kmrdhruv
Copy link
Collaborator

handing for shard re-assignment on consumer node failure/restart.

Closes #148

…ution and updates on subscription operation for a subscription
…criptions. This includes

- main sub, retry topic & sub, dlt topic & sub
- basic shard/partitioning based on qps/throughput limits
- subscription running status controller API
- subscription provisioning status in rest API
Moved internal queue type and topic partition related entities to entities module.
- Add active produce/consume topic/subscription to composite entities
- Move default topic/node capacity to config from hard coded values.
- moved varadhitopic factory/service to server module.
- refactoring related to start subscription in consumer
Copy link

Test Results

221 tests   221 ✅  43s ⏱️
 51 suites    0 💤
 51 files      0 ❌

Results for commit 7d88e6a.

@kmrdhruv kmrdhruv merged commit 57a59b4 into master Jun 26, 2024
2 checks passed
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.

handle consumer restart/crash in controller for subscription reassignment.
1 participant