我们有一种情况需要将已登陆 Azure 事件中心的消息发送到外部 Kafka 主题中的主题。没有转换,只是从 AEH 读取事件并转发给 Kafka。从数量的角度来看,我们每天可能会收到 1-3 百万条消息,因此该服务应该一直运行。我的问题是什么是最好的 Azure 计算服务来做一些如此基本但一直运行的事情?
对于上下文:我们目前使用 Azure Functions 在生态系统中做无数的事情,但它们要么被触发,要么是定时和短暂的。我们也在其他地方使用 Service Fabric。认为 Durable Functions 在这里也很有趣。也许甚至是低代码,没有代码的方式来做到这一点。
我建议在 eventhub 中启用 Kafka 兼容模式,然后为此使用常规的 Kafka 工具,例如 MirrorMaker2