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