kafka2elasticsearch:卡夫卡2弹性搜索
kafka2es作用订阅kafka集群的某个topic的数据到es中,并根据订阅的日志内容product,event_time创建索引,索引名为aqueducts_product_年-月-日,type由service决定
kafka2es使用编译命令:
mvn -f pom.xml assembly:assembly
配置文件为.json文件,例如kafka2es-example.json:
{
\"zkHost\":\"xxx\", //zk的ip或者vip
\"esHost\":\"xxx\", //es集群的ip或者vip
\"esCluster\":\"es_test\", //es集群的名字
\"kafkaTopic\":\"xxx\", //订阅kafka的topic
\"kafkaGroup\":\"xxxx\", //订阅kafka的group
}