Hi everyone,

I have a use case where a message can take longer than '
heartbeat.interval.ms' to be processed by my application. As I understand
the heartbeats of consumer are done while the poll method is invoked.

I would like to instantiate a worker thread to process the messages but I
need to wait for the messages completion before polling again.

Is there a way to force the consumer to make an heartbeat without polling
new messages ?

Thanks,

-- 
Florian HUSSONNOIS

Reply via email to