Ira Klotzko

Thanks Nevon, we'll take a look at that, I always took the REQUEST_QUEUE_SIZE from the documentation as a change on how many in-flights you could have but looking at socketRequest...

Let's say you were to have a method allowing you to send a kafka message asynchronously receiving a callback on successful (or unsuccessful) ack. The messages in the queue would...

Why timeout, or drop messages rather than pause the intake of data going to your producer (when max_pending_len > pending_len) ? The driver of our producer messages is a consumer...

Also, @Nevon had a very nice idea of using an instrumentation event to track for acks=0 to prevent pileup in the socket. It does not look very difficult to implement...

Anyone?

@syahiaoui do you have the full code to the great example you provided of the consumer(non-following mode)? Thanks again for this, it's very elegant!

@syahiaoui I was able to get it working, thanks, it's a very clear solution for our problem!

hmmm, not sure what you would call them but cutting up a circle into pizza pie-like slices, and using a rectangle to select various items. - ik On Mon, Mar...