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

时间:2021-12-15 16:22:17
【文件属性】:
文件名称: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

网友评论

  • java kafka 集成 es
  • 运行起来会报ClassNotFoundException: org.apache.logging.log4j.util.ReflectionUtil,百度找不到答案
  • 这明明仅仅是ESUtil,完全不是你描述的那样,垃圾!