新增Kafka topic

src/main/java/cn/meteor/beyondclouds/core/queue/consumer/DataItemChangeConsumer.java

@@ -30,7 +30,7 @@ public class DataItemChangeConsumer implements TopicConsumer, ApplicationContext
     private Collection<DataItemChangeListener> listeners;
 
     @Override
-    @KafkaListener(topics = "${beyondclouds.kafka.topics.search-item-update}")
+    @KafkaListener(topics = "${beyondclouds.kafka.topics.data-item-change}")
     public final void onMessage(ConsumerRecord<?, String> record) {
         Optional<String> kafkaMessage = Optional.ofNullable(record.value());
         if (kafkaMessage.isPresent()) {