小伙伴们，你们好呀，我是老寇，跟我一起学习es7.6.2注：请点击我，获取源码目录一、引入依赖配置pom.xml二、配置application-dev.yml(生产就克隆application-dev改成生产配置)三、配置ES注解四、配置es及swagger五、ES工具类（索引相关配置不懂的，请查看elasticsearch7.6.2-索引管理）七、测试es一、引入依赖配置pom.xmlorg.springframework.bootspring-boot-starter-webio.springfoxspringfox-swagger2io.springfoxspringfox-swagge

我想将KAFKA主题用作ES-Indexname的一部分。这是我的示例，但这不起作用：input{kafka{...decorate_events=>true}}filter{mutate{add_field=>{"[@metadata][index]"=>"[kafka][topic]"}}}output{elasticsearch{index=>"kafka-%{[@metadata][index]}-%{+YYYY.MM.dd}"...}}有人可以在logstash.conf中找到问题吗？看答案你好，这是工作配置：input{kafka{...decorate_events=>true}

0.引言最近接到一个需要，需要在springdataelasticsearch关联的实体类中动态的根据配置文件动态创建索引名称，比如开发环境下索引名称为user-dev，测试环境下为user-test，生产环境为user-prod一开始接到这个需要觉得很怪，因为不同环境的区分直接搭建不同的es服务器环境不就行了吗，为什么要这么麻烦来处理呢？后来了解到是因为当前项目成本受限，需要隔离开发环境和测试环境用的同一台服务器，于是就产生了这个奇怪的需求。其实想想，不排除某些场景下，就需要动态的创建索引名称。于是今天我们就来看看怎么实现这个需求1.解决首先我们需要明确目标，我们要动态定义这里的indexN

SpringBoot实现注解的属性动态注入。以ElasticSearch的java查询的indexName为例背景配置文件：conf.properties配置文件载入类：PropertyConfig.java实体类：EsNetMessage.java注入流程背景最近接了个需求，需要每天从ElasticSearch（下称es）中取出数据然后持久化到mysql数据库里，而我们项目的es里的数据都是以日期作为index来存储的，那么就需要用程序每天定时进行拉取。我们用springboot的spring-boot-starter-data-elasticsearch（类似mybatis的框架）进行数据