Bob Potter comments

Repositories
Issues
Comments

Results 15 comments of


                                            Bob Potter

added a set_offset() method to partition_consumer.rb

@bkao it may be the case that the message you are trying to fetch is larger than the max_fetch_size. Do you know of anyway to reproduce the issue? I'm hesitant...

Add an optional response callback to Producer

@kerinin true. I'll add it to the top-level Producer example

Add an optional response callback to Producer

@kerinin @atharrison There is also another route that we could go which is providing a future-like object which the user would iterate through once completed.

Add an optional response callback to Producer

Cool. Just realized this design didn't consider errors that occur before we send the request (like not being able to connect to a leader). I don't know if it makes...

Connection re-use

This looks good. Can you extract the equivalent config finding logic into a separate method, #current_pool is getting kinda busy.