-
2 votesanswersviews
使用elasticsearch-hadoop库从storm到elasticsearch索引元组不起作用
我想将文档索引到Storm中的Elasticsearch,但我无法将任何文档编入索引到Elasticsearch . 在我的拓扑结构中,我有一个KafkaSpout,它将这样的json({tweetId“:1,”text“:”hello“})发送到一个EsBolt,它是来自elasticsearch-hadoop库的本机螺栓,它将Storm Tuples写入Elasticsearch(doc在这里...