上传者: liuyunfeng2009
|
上传时间: 2021-12-06 11:27:21
|
文件大小: 9KB
|
文件类型: -
消费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