Damien Krotkine comments

Results 34 comments of


                                            Damien Krotkine

implement unsubscribing from a topic. And getting current topic

Ah that's why I also saw strange behaviours... Don't we have a hook to these subscribers and workers ?

implement unsubscribing from a topic. And getting current topic

I don't think it's a problem if it requires the user to write some code to properly shut down the subscribers/workers. But it would be g reat to at least...

add state to the group consumer

Thank you @objectuser for your swift reply ! I totally see your point, but I guess I'm not good enough in Elixir to see how I can achieve what you...

add state to the group consumer

Thanks for mentioning the Registry, it's something I might want to use indeed. I can't really afford having a bottleneck of an Agent or an ets table for storing the...

add state to the group consumer

So, I've been using kaffe with this modification, and it has a lot of advantages. Among them: - simplicity, no need to take care of maintaining state, no need to...

add state to the group consumer

Any progress ?

add state to the group consumer

I agree with keeping back compat by default. Not sure about using a behavior

[Question] dynamically registering new topics

thanks. I'm going to hack kaffe to make it dynamic, as I have a pool of boxes that I need to consume various topics at different time. I'm going to...

[Question] dynamically registering new topics

see #58

[Question] dynamically registering new topics

It’s not a domain specific situation. To me it is mandatory that à Kafka client allows this. The official clients in other languages do provide this. My need is very...