文件名称:kafka elasticsearch
文件大小:7KB
文件格式:ZIP
更新时间:2020-03-22 04:27:49
kafka es
通过获取kafka消息列队消费发送到elasticsearch做持久存储
【文件预览】:
kafka
----MessageToESThread.java(1KB)
----service-es-beans.xml(2KB)
----KafkaConsumerService.java(3KB)
----ESClientFactory.java(2KB)
----ESUtil.java(4KB)
----ConsumerMsgThread.java(4KB)