目前，我有elastic indexer插件，可批量编写docs到Elastic。我现在想将这些写到rabbitmq交换中。
我尝试在 flex 插件的write方法内写入交换，而当从本地手动运行时此方法有效，但在hadoop集群中运行时不起作用。
我也看过publish-rabbitmq插件，但这看起来是事件集中的，而不是文档的。
是否有可用的插件来完成我想做的事情或需要编写自己的插件？
最佳答案
您正在寻找和索引类似于https://github.com/apache/nutch/tree/master/src/plugin/indexer-solr的插件，但该插件适用于RabbitMQ，目前不存在。一段时间前，我已经为客户做过类似的事情，但可惜它不是开源的。
基本上，您需要做的是在一个从IndexWriter扩展的类中编写您自己的实现，并仅填充每种方法的实现。
看一看indexer-solr，indexer-elastic和https://github.com/apache/nutch/blob/master/src/plugin/indexer-dummy/，它们是最简单的，并且完全作为学习/测试工具提供。