From 5c072f8eb1b05b54d6ef682c3eb42b076d861885 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=96=AF=E7=8B=82=E7=9A=84=E7=8B=AE=E5=AD=90Li?=
 <15040126243@163.com>
Date: Tue, 9 Jul 2024 14:49:40 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E4=BC=98=E5=8C=96=20kafka=20stream=20?=
 =?UTF-8?q?=E9=BB=98=E8=AE=A4=E5=BC=80=E5=90=AF=E9=81=BF=E5=85=8D=E5=B0=8F?=
 =?UTF-8?q?=E7=99=BD=E6=90=9E=E4=B8=8D=E6=87=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/org/dromara/stream/config/KafkaStreamsConfig.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/config/KafkaStreamsConfig.java b/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/config/KafkaStreamsConfig.java
index 02e441a8..a73cb420 100644
--- a/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/config/KafkaStreamsConfig.java
+++ b/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/config/KafkaStreamsConfig.java
@@ -4,6 +4,7 @@ import org.apache.kafka.streams.StreamsBuilder;
 import org.apache.kafka.streams.kstream.KStream;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.annotation.EnableKafkaStreams;
 
 /**
  * kafka stream 配置
@@ -11,6 +12,7 @@ import org.springframework.context.annotation.Configuration;
  * @author LionLi
  */
 @Configuration
+@EnableKafkaStreams
 public class KafkaStreamsConfig {
 
     @Bean