Registry / messaging / karafka

karafka

JSON →
library2.5.9rbrubygemsunverified

Ruby and Rails efficient Kafka processing framework for handling large-scale event streams.

messagingweb-framework
gem install karafka
github ↗homepage ↗docs ↗
INSTALL
IMPORT
SIG · KARAFKA
K
karafka
messagingrubyv2.5.9
harness data pending
Install & Compatibility
Where this runs

No compatibility data collected yet for this library.

Code
Verified usage

Verified import paths — ran on the pinned version, not inferred.

Karafka
✓ require 'karafka'

Define a Kafka consumer and boot the app

require 'karafka' class MyConsumer < Karafka::BaseConsumer def consume params_batch.each { |message| puts message.payload } end end Karafka::App.boot!
Debug
Known issues
breakingRequires Ruby 2.7+ and Kafka broker 2.5+
fix
Upgrade Ruby or use an older Karafka version if needed.
affects: >= 2.0.0
Upgrade
Version history
2.5.9latest on RubyGems
Audit
Dependencies

No dependency data recorded yet.

Agent activity
23 hits · last 30 days
node
22
OpenAI (training)
1
Resources
githubhttps://github.com/karafka/karafka ↗
homepagehttps://karafka.io ↗
docshttp://www.rubydoc.info/gems/karafka/ ↗
karafka — gem install karafka · libregistry