java语言kafka数据批量导入到Elasticsearch实例

【文件属性】：

文件名称：java语言kafka数据批量导入到Elasticsearch实例

文件大小：9KB

文件格式：JAVA

更新时间：2021-12-15 16:22:17

kafka Elasticsearc 批量导入

消费kafka数据，然后批量导入到Elasticsearch,本例子使用的kafka版本0.10，es版本是6.4，使用bulk方式批量导入到es中，也可以一条一条的导入，不过比较慢。 org.elasticsearch elasticsearch 6.4.0 org.elasticsearch.client elasticsearch-rest-high-level-client 6.4.0 org.elasticsearch.client transport 6.4.0 org.apache.kafka kafka-clients 0.10.1.0