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
- one more spec for marking in transaction and piping
- Provide context-based offset movement and earliest support
- 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
- Remove default from async_call once web released
- Untangle rdkafka logger for Karafka and WaterDrop to have granular notifications
- Replace rspec with minitest for the whole ecosystem
- Consider supporting dynamic context aware DLQ topics
- Docs
- Subscribe to help with docs for this repo and come back later