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.org/documentation/#design_pull.
Kind regards, Tom On Wed, Jan 8, 2020 at 9:09 AM Jonathan Santilli <jonathansanti...@gmail.com> wrote: > 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 <tfo...@qti.qualcomm.com> > wrote: > > > 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 > > >
