lasticSearch自身提供了一个River机制,用于同步数据。 这里可以找到官方目前推荐的River: 但是官方没有提供HBase的River。 其实ES的River非常简单,就是一个用户打包好的jar包,ES负责找到一个node,并启动这个River。如果node失效了,会自动找另外一个node来启动这个River。