java语言kafka数据批量导入到Elasticsearch实例
消费kafka数据,然后批量导入到Elasticsearch,本例子使用的kafka版本0.10,es版本是6.4,使用bulk方式批量导入到es中,也可以一条一条的导入,不过比较慢。 org.elasticsearch elasticsearch 6.4.0
下载地址
用户评论
运行起来会报ClassNotFoundException:org.apache.logging.log4j.util.ReflectionUtil，百度找不到答案
这明明仅仅是ESUtil，完全不是你描述的那样，垃圾！