我们有一个将数据转发到 MapR Streams(Kafka)的应用程序。问题是,如果网络链接断开,那么数据就会丢失,因为应用程序本身不会保留历史记录。我们正在考虑在同一台虚拟机上安装某种消息总线,以便应用程序可以在本地消息总线中缓冲数据。另一个进程将从该消息总线读取并转发到 MapR Streams。在我做这一切之前,我想知道是否有消息转发器这样的东西?我知道 Splunk 有这个概念,但它特定于 Splunk。这将是一个在与应用程序相同的服务器上运行的进程,接收消息,将它们转发到另一个消息总线,并在失败时将它们存储在本地。一旦发送,消息就会被删除。
消息转发至 MapR Streams/Kafka
•
kafka