You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by lx <lx...@facemeng.com.cn> on 2018/09/20 02:01:15 UTC
Does kafka support the delay queue
Hi,kafka.apache.org
Does kafka support delay queues?how can kafka implement delay queues?
I hope my doubts can be answered.thanks
Sincerely
Lx
Re: Does kafka support the delay queue
Posted by Subash Konar <su...@gmail.com>.
Approach 1: Yes it can be.You have to create a dedicated topic for the same
and I think the limitation will be all the messages to be processed should
have same delay time in that particular topic and use decision making along
with some loop for the messages.
Approach 2:I believe the feature in versions above 0.10+ by using the new
timestamp per message.
Approach 3:Store the messages in RDBMS using indexing and put these
messages as per their execution time in topic.You can refer here
<https://stackoverflow.com/questions/26890222/how-to-achieve-delayed-queue-with-apache-kafka>
for
more details
--
Thanks and Regards,
Subash Konar
On Thu, Sep 20, 2018 at 7:31 AM lx <lx...@facemeng.com.cn> wrote:
> Hi,kafka.apache.org
> Does kafka support delay queues?how can kafka implement delay queues?
> I hope my doubts can be answered.thanks
>
>
> Sincerely
> Lx
--
Thanks and Regards,
Subash Konar