|
@@ -38,7 +38,7 @@ import java.util.Set;
|
|
|
public class KafkaCommonConfig implements InitializingBean {
|
|
|
|
|
|
@Value("${spring.kafka.consumer.topics}")
|
|
|
- private String edgeTopic;
|
|
|
+ private String topics;
|
|
|
|
|
|
private final KafkaProperties properties;
|
|
|
|
|
@@ -111,7 +111,7 @@ public class KafkaCommonConfig implements InitializingBean {
|
|
|
|
|
|
private String wireTopics(){
|
|
|
Set<String> topicSet = new HashSet<>();
|
|
|
- topicSet.add(edgeTopic);
|
|
|
+ topicSet.add(topics);
|
|
|
return StringUtils.join(topicSet,",");
|
|
|
}
|
|
|
}
|