kafka修改

src/main/java/com/lwby/marketing/att/UniversalProcess.java

@@ -23,7 +23,7 @@ public class UniversalProcess {
     @Resource
     public JdbcTemplate lwbyJdbcTemplate;
 
-    @Resource
+    @Resource(name = "novelKafka")
     public KafkaTemplate<String, String> novelKafkaTemplate;
 
     @Resource

src/main/java/com/lwby/marketing/conf/KafkaProducerConfig.java

@@ -39,7 +39,7 @@ public class KafkaProducerConfig {
         return new DefaultKafkaProducerFactory<>(producerConfigs());
     }
 
-    @Bean
+    @Bean(name = "novelKafka")
     public KafkaTemplate<String, String> novelKafkaTemplate() {
         return new KafkaTemplate<String, String>(producerFactory());
     }

src/main/java/com/lwby/marketing/conf/StoryKafkaProducerConfig.java

@@ -39,7 +39,7 @@ public class StoryKafkaProducerConfig {
         return new DefaultKafkaProducerFactory<>(producerConfigs());
     }
 
-    @Bean(name = "storyKafkaTemplate")
+    @Bean(name = "storyKafka")
     public KafkaTemplate<String, String> storyKafkaTemplate() {
         return new KafkaTemplate<String, String>(producerFactory());
     }

src/main/java/com/lwby/marketing/controller/AttrController.java

@@ -41,10 +41,7 @@ public class AttrController {
     @Resource
     DyStoryUniversalProcess up;
 
-    @Resource
-    private KafkaTemplate<String, String> novelKafkaTemplate;
-
-    @Resource
+    @Resource(name = "storyKafka")
     private KafkaTemplate<String, String> storyKafkaTemplate;
 
     @Resource