kaffe
kaffe copied to clipboard
spreedly
An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.
Consumer options are set directly in config inside `config :kaffe, consumer: opts` How about moving these options to supervisor options to enable opportunity to run several separate consumers for different...
Hi everyone, nice work done with this library. I want to know, if have plans to add some examples of how we can do some tests with ExUnit in our...
Hi, I've implemented new public functions to accept the `client_name` as parameter and a new function to stop the client to a given `client_name`. It's useful to switch the Kafka...
Kaffe tries to raise or reraise an error that is not an exception: > [error] 20:20:20.999 GenServer :"Elixir.Kaffe.GroupManager.my_group" terminating ** (ArgumentError) raise/1 and reraise/2 expect a module name, string or...
Hello Folks, It would be really useful to allow topic-auto creation from both the publisher and consumer since sometimes it is a lot more complicated to do it from the...
Spent some time addressing an issue fixed by https://github.com/spreedly/kaffe/pull/118, trying to use the chance to bring some 💜 to kaffe! I've tested and it's passing on https://github.com/rodrigues/kaffe/pull/1
In case the kafka cluster is temporarily unavailable, when subscribe_to_topics retries are exhausted, it simply exits the function without crashing. When kafka cluster is back, if that happened after `client_down_retry_expire`,...
I can't find anything in the docs or the code. I'm trying to pass a map `%{value: value, headers: headers}` as it seems supported by brod, but I get this...
Hi, There's `:worker_mod` app env that can be configured, currently used by the subscriber when calling `process_messages/5`. The WorkerSupervisor starts `Kaffe.Worker` directly though, using the same setting, we can change...