Назад | Перейти на главную страницу

Пересылка сообщений в потоки MapR / Kafka

У нас есть приложение, которое пересылает данные в MapR Streams (Kafka). Проблема в том, что если сетевое соединение выходит из строя, данные теряются, поскольку само приложение не хранит историю. Мы планируем установить какую-то шину сообщений на той же виртуальной машине, чтобы приложение могло буферизовать данные в локальной шине сообщений. Другой процесс будет читать из этой шины сообщений и перенаправлять в потоки MapR. Прежде чем я это сделаю, мне интересно, существует ли такая вещь, как пересылка сообщений? Я знаю, что у Splunk есть такая концепция, но она специфична для Splunk. Это будет процесс, который выполняется на том же сервере, что и приложение, принимает сообщения, пересылает их в другую шину сообщений и сохраняет их локально, если это не удается. После отправки сообщение будет удалено.