© 1999-2048 dssz.net 粤ICP备11031372号
[kafka] java语言kafka数据批量导入到Elasticsearch实例
说明: 消费kafka数据,然后批量导入到Elasticsearch,本例子使用的kafka版本0.10,es版本是6.4,使用bulk方式批量导入到es中,也可以一条一条的导入,不过比较慢。 pom文件 org.elasticsearch elasticsearch 6.4.0 org.elasticsearch.client elasticsearch-rest-high-level-client 6.4.0 org.elasticsearch.client transport 6.<liuyunfeng2009> 上传 | 大小:9kb