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
  \"t