是否可以设置Kafka的交付时间

6uxekuva  于 2022-12-11  发布在  Apache
关注(0)|答案(1)|浏览(116)

我是Kafka的新手。例如,我通过producer在topic上发布一条消息。该主题的所有订阅者都会得到通知。
但我想发送基于预定时间的延迟消息。我将张贴与交付时间的消息。而且我需要创建不同交付时间的多个主题
防爆

> Topic: Topic_1, Message:"Good Morning", Delivery Time:9:00:00
> Topic: Topic_1, Message:"Good Afternoon", Delivery Time:13:00:00
> Topic: Topic_2, Message:"Good Morning", Delivery Time:9:30:00
> Topic: Topic_2, Message:"Good Afternoon", Delivery Time:13:30:00

有可能做到这一点吗?或者任何其他的工具或软件是可用的,为我的要求?或者任何其他的技术/方法,通过编码来做到这一点?我使用php或Go Lang

bq3bfh9z

bq3bfh9z1#

Kafka没有这方面的特性。你需要在你自己的一些应用程序中排队记录,例如cron +循环一个带有时间戳的文件,然后从文件中弹出,检查时间,并发送到Kafka生产者。大多数Kafka客户端都有通过AdminClient API创建主题的方法

相关问题