我是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
1条答案
按热度按时间bq3bfh9z1#
Kafka没有这方面的特性。你需要在你自己的一些应用程序中排队记录,例如
cron
+循环一个带有时间戳的文件,然后从文件中弹出,检查时间,并发送到Kafka生产者。大多数Kafka客户端都有通过AdminClient API创建主题的方法