erlkaf
erlkaf copied to clipboard
silviucpp
Erlang kafka driver based on librdkafka
Hi, I am asked to add a timestamp to messages when producing a message. I am currently using brod but would like to migrate to erlkaf eventually. I would like...
urning the consumer into gen_statem with polling and paused state. TODO update consumer_group and manager to hande calls.
Is it possible to support this feature here? Is there a road map for other features? https://kafka.apache.org/0102/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#:~:text=Kafka%20supports%20dynamic%20controlling%20of,future%20poll(long)%20calls.
Hi, I've recently started testing erlkaf after a year using brod, and I'm very impressed of how it works perfectly well. Congratulations! Have anyone tried to implement a consumer ->...
I called the `erkaf:produce` function and got `{:error, 29}`, which is not very helpful. The signature of the function says that reason is anything, but there is already an internal...
erlkaf version: 2.0.8 Hi Silviu, Thanks for your work. We are currently using erlkaf in our server. However, I noticed sometimes when partition rebalance is triggered, some partition consumers may...
Closes #56 This is my attempt at implementing this function. This still needs some testing. I could only find a way to delete topics in the admin API, the reference...
During the installation of projects using erlkaf on a fresh Ubuntu system, I encountered errors due to the absence of the zlib1g-dev package. As related in this image: 
It would be useful for cleaning up the state of the broker when using erlkaf in tests that produce to random topics that we are not really interested to be...
I'm looking at switching from `Elsa` to `erlkaf`. My use case is to consume entire Kafka topics to populate in-memory caches on application boot. This requires two things from my...
