Corey Auger comments

Results 17 comments of


                                            Corey Auger

Endpoint url support

Can AkkaConsumber inherit from a common base trait?

Sounds good :)

Highlevel consumer using executor

Ok looks good :) I will add this to my code and do another commit that collapses everything into one. Thanks.

Question : How can I consume my kafka topic as fast as possible ?

I am having a similar issue. Did you manage to find a solution to yours? Thanks :)

Question : How can I consume my kafka topic as fast as possible ?

Thanks for the reply @sclasen. I seem to have about a 1 to 3 second delay before I receive a message to my receiver actor. ``` scala val props =...

Question : How can I consume my kafka topic as fast as possible ?

Hi @sclasen .. thanks again for your help in this. I have put a small dump of the log file here https://gist.github.com/coreyauger/0ce0b743c4e987218238 The log explodes fast as akka is logging...

Question : How can I consume my kafka topic as fast as possible ?

There are a few use cases.. but one of which is IM or (chat) based messaging.. so low latency is certainly required for this. In this case am I better...

Question : How can I consume my kafka topic as fast as possible ?

I will take a look at this. Would there be any interest if I submit a pr for another type of low latency consumer for this lib? Or is this...

Question : How can I consume my kafka topic as fast as possible ?

Hi @sclasen , I have built a initial actor that is working well for my use case. It has been modelled from the Kafka HighLevel Consumer. https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example Here is the...

Question : How can I consume my kafka topic as fast as possible ?

That was indeed my original implementation.. but I continue to get the time-out exception. There is most likely a setting that I can pass in for an infinite wait... I...