kafka中的@KafkaListener如何动态获得topic

写个博客纪念一下。
首先，引入依赖：

  <dependency>
        <groupId>org.springframework.kafka</groupId>
        <artifactId>spring-kafka</artifactId>
  </dependency>

很重要，一定要看好，依赖困扰了我很久
其次写一个 KafkaTopicConfig类，继承InitializingBean，重写afterPropertiesSet()方法。
如下：

```java
@Configuration
public class KafkaTopicConfig implements InitializingBean {

    @Override
    public void afterPropertiesSet() {
    //获取topic
        String topics = Sets.newHashSet(KafkaTopicEnum.values()).stream()
                .map(KafkaTopicEnum::getTopic).collect(Collectors.joining(","));
     //系统写入
        System.setProperty("topics", topics);
    }
}

记得配置文件中加上 topics：
然后
 @KafkaListener(topics = "#{'${topics}'.split(',')}")
在要调用 @KafkaListener的类前加上@DependsOn(value = "kafkaTopicConfig")，确保kafkaTopicConfig类在此之前加载。
不然还会报错。

注意：@KafkaLisener中的topics是string[]类型，一定要注意传入参数的属性，不然会报value '[Ljava.lang.String;@1fb8997'的错误，一定要注意一下！