karafka
https://github.com/karafka/karafka
Ruby
Ruby and Rails efficient Kafka processing framework
Triage Issues!
When you volunteer to triage issues, you'll receive an email each day with a link to an open issue that needs help in this project. You'll also receive instructions on how to triage issues.
Triage Docs!
Receive a documented method or class from your favorite GitHub repos in your inbox every day. If you're really pro, receive undocumented methods or classes and supercharge your commit history.
2 Subscribers
Add a CodeTriage badge to karafka
Help out
- Issues
- Rescue, report and virtualize to one partition when errors occur in the partitioner
- Consider providing a fast-exit way out of a consumer that would not raise an error but would not mark as consumed
- examine the sleep calls within the integration specs to identify any repetitions, and then establish helper methods for those instances
- Dynamic DNS changes of brokers IPs are not refreshed fast enough
- Untangle rdkafka logger for Karafka and WaterDrop to have granular notifications
- Static membership fencing error is not propagated explicitely enough
- Cleanup config and monitoring references and use the config injector
- Expand the polling yield model with min count
- Run all specs in the ecosystem against RedPanda
- Spec instabilities
- Docs
- Subscribe to help with docs for this repo and come back later