: 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
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
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
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
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