RabbitMQ连接到Logstash的RCP

Question

我们目前正在将我们的系统连接到elasticsearch。我们的想法是将我们的数据推送给经纪人（RabbitMQ），然后将其转移到elasticsearch。

由于在最新的elasticsearch中河流已被弃用，我发现的唯一选择是在broker和elasticsearch之间使用logstash。

它的工作原理是这样的：

自己的系统 - >的RabbitMQ - > Logstash - > elasticsearch

我可以成功连接所有系统，但我们有一些要求是在他们能够继续之前需要等待成功的回应。我发现RabbitMQ的RCP正是我所需要的，因为我可以等到我收到消费者的回应后才继续。

我的问题是我找不到任何地方如何配置logstash使用回调队列。

logstash有没有办法使用RCP？或者，在经纪人的帮助下，是否有其他方法可以将数据导入elasticsearch？

Answer 1

队列代理提供的主要优点之一是能够分离您的系统并利用异步处理。如果您的系统确实需要同步确认记录已成功插入到ElasticSearch中，那么最好让您的应用程序直接调用ElasticSearch API。否则，如果数据被插入到ElasticSearch中，则应用程序应该能够处理失败。