This is an example application which uses:
- Karafka framework
2.4
to receive messages from Apache Kafka server - WaterDrop gem to send messages back to Kafka
- Karafka-Testing provides RSpec helpers, to make testing of Karafka consumers much easier
Please run bundle install
to install all the dependencies.
After that, following commands are available. You should run them in the console.
Create all needed topics:
bundle exec karafka topics migrate
Run Karafka server to consume messages, process and send messages:
bundle exec karafka s
Generate initial messages to Kafka server by sending them using WaterDrop:
bundle exec rake waterdrop:send
You can also run RSpec specs to see how the testing RSpec library integrates with RSpec:
bundle exec rspec spec