UPDATE-修改kafka主题内容

src/main/java/com/ywt/biz/common/config/kafka/KafkaAnalyzeProducer.java

@@ -73,7 +73,7 @@ public class KafkaAnalyzeProducer {
             topic = topic.replaceAll("/","_");
         }
         String finalTopic = topic;
-        kafkaTemplate.send(topic, message).addCallback(new ListenableFutureCallback<Object>() {
+        kafkaTemplate.send(finalTopic, message).addCallback(new ListenableFutureCallback<Object>() {
             @Override
             public void onFailure(@NotNull Throwable throwable) {
                 log.error("----事件kafka记录解析完成放入topic：{}，发送失败{}", finalTopic, message, throwable);