Sorry, not queue. I guess this is different than rabbitmq. Kafka consumer pulls data from the broker. There’s probably no event triggers to call a function. [Kafka Architecture - Kafka Zookeeper Coordination Diagram]
From: Tom Bentley <[email protected]> Sent: Wednesday, January 8, 2020 1:38 AM To: Users <[email protected]> Cc: Tavares Forby <[email protected]> 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 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 <[email protected]<mailto:[email protected]>> 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 <[email protected]<mailto:[email protected]>> 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 >
