From cb2ff94226c5019a7b2fa6de87b8be67b203ed10 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, 16 Jul 2024 11:19:38 +0800
Subject: [PATCH] =?UTF-8?q?remove=20=E5=88=A0=E9=99=A4=20kafka-streams=20?=
 =?UTF-8?q?=E6=89=80=E6=9C=89=E4=BA=BA=E9=83=BD=E4=B8=8D=E4=BC=9A=E7=94=A8?=
 =?UTF-8?q?=E4=B9=9F=E4=B8=8D=E5=AD=A6=E6=80=8E=E4=B9=88=E7=94=A8=20?=
 =?UTF-8?q?=E5=88=A0=E9=99=A4=E4=BA=86=E4=BA=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ruoyi-example/ruoyi-test-mq/README.md         |  2 +-
 ruoyi-example/ruoyi-test-mq/pom.xml           |  4 ---
 .../stream/config/KafkaStreamsConfig.java     | 29 -------------------
 3 files changed, 1 insertion(+), 34 deletions(-)
 delete mode 100644 ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/config/KafkaStreamsConfig.java

diff --git a/ruoyi-example/ruoyi-test-mq/README.md b/ruoyi-example/ruoyi-test-mq/README.md
index 1f7c5fb3..1039f1c2 100644
--- a/ruoyi-example/ruoyi-test-mq/README.md
+++ b/ruoyi-example/ruoyi-test-mq/README.md
@@ -4,7 +4,7 @@
 
 1. rabbitmq: 普通消息、延迟队列
 2. rocketmq：普通消息、事务消息、延迟消息
-3. kafka：普通消息、stream流的使用
+3. kafka：普通消息
 
 
 ## 使用方式
diff --git a/ruoyi-example/ruoyi-test-mq/pom.xml b/ruoyi-example/ruoyi-test-mq/pom.xml
index a37d75ee..dc29d327 100644
--- a/ruoyi-example/ruoyi-test-mq/pom.xml
+++ b/ruoyi-example/ruoyi-test-mq/pom.xml
@@ -33,10 +33,6 @@
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.apache.kafka</groupId>
-            <artifactId>kafka-streams</artifactId>
-        </dependency>
 
         <dependency>
             <groupId>org.dromara</groupId>
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
deleted file mode 100644
index a73cb420..00000000
--- a/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/config/KafkaStreamsConfig.java
+++ /dev/null
@@ -1,29 +0,0 @@
-package org.dromara.stream.config;
-
-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 配置
- *
- * @author LionLi
- */
-@Configuration
-@EnableKafkaStreams
-public class KafkaStreamsConfig {
-
-    @Bean
-    public KStream<String, String> demoStream(StreamsBuilder builder) {
-        // 输入主题
-        KStream<String, String> source = builder.stream("input-topic");
-        // 转换逻辑：这里只是简单地将消息转换为大写
-        KStream<String, String> processed = source.mapValues(value -> value.toUpperCase());
-        // 输出到另一个主题
-        processed.to("output-topic");
-        return source;
-    }
-
-}