RE: callback function

2020-01-08 Thread Tavares Forby
: Tavares Forby Subject: [EXT] Re: callback function Tavares, if you're asking about the consumer then I think you might have a misconception about how it works: The application calls poll() to fetch the latest records from the broker(s). The broker is not pushing records into some queue i

Re: callback function

2020-01-08 Thread M. Manna
Hey Tavares, On Wed, 8 Jan 2020 at 09:38, Tom Bentley wrote: > Tavares, if you're asking about the consumer then I think you might have a > misconception about how it works: The application calls poll() to fetch the > latest records from the broker(s). The broker is not pushing records into > s

Re: callback function

2020-01-08 Thread Tom Bentley
Tavares, if you're asking about the consumer then I think you might have a misconception about how it works: The application calls poll() to fetch the latest records from the broker(s). The broker is not pushing records into some queue in the consumer. It might be worth reading https://kafka.apache

Re: callback function

2020-01-08 Thread Jonathan Santilli
Hello, when you say "something is new in the queue" you mean a new message/record is available in a partition within a topic? Cheers! On Tue, Jan 7, 2020, 8:46 PM Tavares Forby wrote: > Hi, > > Is there a method in which a function can wake when something is new in > the queue? This has to be n

callback function

2020-01-07 Thread Tavares Forby
Hi, Is there a method in which a function can wake when something is new in the queue? This has to be non-blocking to the main thread. Thanks, -Tavares