remove 删除 kafka-streams 所有人都不会用也不学怎么用 删除了事

ruoyi-example/ruoyi-test-mq/README.md

@@ -4,7 +4,7 @@
 
 1. rabbitmq: 普通消息、延迟队列
 2. rocketmq：普通消息、事务消息、延迟消息
-3. kafka：普通消息、stream流的使用
+3. kafka：普通消息
 
 
 ## 使用方式

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>

ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/config/KafkaStreamsConfig.java

@@ -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;
-    }
-
-}