From 0bc9ac5954df35a498e9fabda339bf044e1409bc Mon Sep 17 00:00:00 2001
From: lau572 <1010031226@qq.com>
Date: Tue, 25 Feb 2025 11:17:42 +0800
Subject: [PATCH] =?UTF-8?q?bean=E6=B3=A8=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../business/message/device/subscribe/KafkaTopicProducer.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/zc-business/src/main/java/com/zc/business/message/device/subscribe/KafkaTopicProducer.java b/zc-business/src/main/java/com/zc/business/message/device/subscribe/KafkaTopicProducer.java
index 5827937d..f0eddb7c 100644
--- a/zc-business/src/main/java/com/zc/business/message/device/subscribe/KafkaTopicProducer.java
+++ b/zc-business/src/main/java/com/zc/business/message/device/subscribe/KafkaTopicProducer.java
@@ -5,6 +5,7 @@ import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.clients.producer.RecordMetadata;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
 
 import java.util.Properties;
 import java.util.concurrent.ExecutionException;
@@ -14,6 +15,7 @@ import java.util.concurrent.ExecutionException;
  *
  */
 @Slf4j
+@Configuration
 public class KafkaTopicProducer {
     @Value("${kafka.bootstrap-servers}")
     private String servers;