Skip to content

Initialize `Waterdrop`

Daniel Khaapamyaki requested to merge waterdrop into main

Waterdrop is a kafka producer library for ruby

https://github.com/karafka/waterdrop

Since our service is only producing events Waterdrop seems to be the easiest solution to get started.

The waterdrop.rb initializer starts a connection to the bootstrap server.

From here onwards we can simply call

$producer.produce_async(topic: 'events', payload: { 'hello' => 'worlds' }.to_json)

Merge request reports