Displaying 1 to 6 from 6 results

karafka-example-app - Karafka and WaterDrop example application

  •    Ruby

This is an example application which uses Karafka framework to receive messages from Apache Kafka server and WaterDrop gem to send messages to Kafka server.To run this application locally you should run Apache Kafka on those hosts and ports which are set in app.rb file.

waterdrop - Ruby-Kafka based aspect oriented library for Kafka messages generating

  •    Ruby

Gem used to send messages to Kafka in an easy way.message that you want to send should be either binary or stringified (to_s, to_json, etc).

worker-glass - Timeout and Reentrancy for your background processing workers

  •    Ruby

WorkerGlass provides optional timeout and after failure (reentrancy) for background processing worker engines (like Sidekiq, Resque, etc).If you don't know what is reentrancy, you can read about it here.




example-app - Karafka WaterDrop and Sidekiq backend example application

  •    Ruby

This is an example application which uses Karafka framework to receive messages from Apache Kafka server, WaterDrop gem to send messages to Kafka server and (for some topics) Karafka Sidekiq Backend (optional) to process them in Sidekiq. Note: Sidekiq usage in Karafka is optional and it is not a default. To use it, you need to use Karafka Sidekiq Backend. It is added here just as an example of possibility to process things in it automatically.

sidekiq-backend - Karafka Sidekiq backend for background messages processing

  •    Ruby

Karafka Sidekiq Backend provides support for consuming (processing) received Kafka messages inside of Sidekiq workers. Note: You can name your application worker base class with any name you want. The only thing that is required is a direct inheritance from the Karafka::BaseWorker class.