Spring Cloud Stream Kafka 入门

qzlyhua · Jun 28, 2020 · 7aed640 · 7aed640
1 parent dcd1f66
commit 7aed640
Show file tree

Hide file tree

Showing 101 changed files with 21 additions and 21 deletions.
diff --git a/README.md b/README.md
@@ -224,7 +224,7 @@
 **Spring Cloud Stream**
 * [《芋道 Spring Cloud Alibaba 消息队列 RocketMQ 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/RocketMQ/?github) 对应 [labx-06-spring-cloud-stream-rocketmq](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-06-spring-cloud-stream-rocketmq)
 * [《芋道 Spring Cloud 消息队列 RabbitMQ 入门》](http://www.iocoder.cn/Spring-Cloud/RabbitMQ/?github) 对应 [labx-10-spring-cloud-stream-rabbitmq](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-10-spring-cloud-stream-rabbitmq)
-* [《芋道 Spring Cloud 消息队列 Kafka 入门》](http://www.iocoder.cn/Spring-Cloud/Kafka/?github) 对应 [labx-11](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-11)
+* [《芋道 Spring Cloud 消息队列 Kafka 入门》](http://www.iocoder.cn/Spring-Cloud/Kafka/?github) 对应 [labx-11-spring-cloud-stream-kafka](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-11-spring-cloud-stream-kafka)
 * [《芋道 Spring Cloud 消息队列 ActiveMQ 入门》](http://www.iocoder.cn/Spring-Cloud/ActiveMQ/?github)
 
 **Spring Cloud Bus**
@@ -340,7 +340,7 @@
 
 * [《Kafka 极简入门》](http://www.iocoder.cn/Kafka/install/?github)
 * [《芋道 Spring Boot 消息队列 Kafka 入门》](http://www.iocoder.cn/Spring-Boot/Kafka/?github) 对应 [lab-03](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-03)
-* [《芋道 Spring Cloud 消息队列 Kafka 入门》](http://www.iocoder.cn/Spring-Cloud/Kafka/?github) 对应 [labx-11](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-11)
+* [《芋道 Spring Cloud 消息队列 Kafka 入门》](http://www.iocoder.cn/Spring-Cloud/Kafka/?github) 对应 [labx-11-spring-cloud-stream-kafka](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-11-spring-cloud-stream-kafka)
 * [《芋道 Spring Cloud 事件总线 Bus Kafka 入门》](http://www.iocoder.cn/Spring-Cloud/Bus-Kafka/?github) 对应 [labx-18](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-18)
 * [《Kafka 书单整理》](http://www.iocoder.cn/Books/Kafka-books-recommended/?github)
 

diff --git a/...x-11-sc-stream-kafka-consumer-ack/pom.xml → ...x-11-sc-stream-kafka-consumer-ack/pom.xml b/...x-11-sc-stream-kafka-consumer-ack/pom.xml → ...x-11-sc-stream-kafka-consumer-ack/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...er-ack/src/main/resources/application.yml → ...er-ack/src/main/resources/application.yml b/...er-ack/src/main/resources/application.yml → ...er-ack/src/main/resources/application.yml
diff --git a/...sc-stream-kafka-consumer-actuator/pom.xml → ...sc-stream-kafka-consumer-actuator/pom.xml b/...sc-stream-kafka-consumer-actuator/pom.xml → ...sc-stream-kafka-consumer-actuator/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...tuator/src/main/resources/application.yml → ...tuator/src/main/resources/application.yml b/...tuator/src/main/resources/application.yml → ...tuator/src/main/resources/application.yml
diff --git a/...11-sc-stream-kafka-consumer-batch/pom.xml → ...11-sc-stream-kafka-consumer-batch/pom.xml b/...11-sc-stream-kafka-consumer-batch/pom.xml → ...11-sc-stream-kafka-consumer-batch/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...-batch/src/main/resources/application.yml → ...-batch/src/main/resources/application.yml b/...-batch/src/main/resources/application.yml → ...-batch/src/main/resources/application.yml
diff --git a/...tream-kafka-consumer-broadcasting/pom.xml → ...tream-kafka-consumer-broadcasting/pom.xml b/...tream-kafka-consumer-broadcasting/pom.xml → ...tream-kafka-consumer-broadcasting/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...asting/src/main/resources/application.yml → ...asting/src/main/resources/application.yml b/...asting/src/main/resources/application.yml → ...asting/src/main/resources/application.yml
diff --git a/...stream-kafka-consumer-concurrency/pom.xml → ...stream-kafka-consumer-concurrency/pom.xml b/...stream-kafka-consumer-concurrency/pom.xml → ...stream-kafka-consumer-concurrency/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...rrency/src/main/resources/application.yml → ...rrency/src/main/resources/application.yml b/...rrency/src/main/resources/application.yml → ...rrency/src/main/resources/application.yml
diff --git a/...-11-sc-stream-kafka-consumer-demo/pom.xml → ...-11-sc-stream-kafka-consumer-demo/pom.xml b/...-11-sc-stream-kafka-consumer-demo/pom.xml → ...-11-sc-stream-kafka-consumer-demo/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...r-demo/src/main/resources/application.yml → ...r-demo/src/main/resources/application.yml b/...r-demo/src/main/resources/application.yml → ...r-demo/src/main/resources/application.yml
diff --git a/...ream-kafka-consumer-error-handler/pom.xml → ...ream-kafka-consumer-error-handler/pom.xml b/...ream-kafka-consumer-error-handler/pom.xml → ...ream-kafka-consumer-error-handler/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...andler/src/main/resources/application.yml → ...andler/src/main/resources/application.yml b/...andler/src/main/resources/application.yml → ...andler/src/main/resources/application.yml
diff --git a/...1-sc-stream-kafka-consumer-filter/pom.xml → ...1-sc-stream-kafka-consumer-filter/pom.xml b/...1-sc-stream-kafka-consumer-filter/pom.xml → ...1-sc-stream-kafka-consumer-filter/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...filter/src/main/resources/application.yml → ...filter/src/main/resources/application.yml b/...filter/src/main/resources/application.yml → ...filter/src/main/resources/application.yml
diff --git a/...tream-kafka-consumer-partitioning/pom.xml → ...tream-kafka-consumer-partitioning/pom.xml b/...tream-kafka-consumer-partitioning/pom.xml → ...tream-kafka-consumer-partitioning/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...ioning/src/main/resources/application.yml → ...ioning/src/main/resources/application.yml b/...ioning/src/main/resources/application.yml → ...ioning/src/main/resources/application.yml
diff --git a/...11-sc-stream-kafka-consumer-retry/pom.xml → ...11-sc-stream-kafka-consumer-retry/pom.xml b/...11-sc-stream-kafka-consumer-retry/pom.xml → ...11-sc-stream-kafka-consumer-retry/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...-retry/src/main/resources/application.yml → ...-retry/src/main/resources/application.yml b/...-retry/src/main/resources/application.yml → ...-retry/src/main/resources/application.yml
diff --git a/...stream-kafka-consumer-transaction/pom.xml → ...stream-kafka-consumer-transaction/pom.xml b/...stream-kafka-consumer-transaction/pom.xml → ...stream-kafka-consumer-transaction/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java b/...fkademo/consumerdemo/listener/MySink.java → ...fkademo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...action/src/main/resources/application.yml → ...action/src/main/resources/application.yml b/...action/src/main/resources/application.yml → ...action/src/main/resources/application.yml
diff --git a/...sc-stream-kafka-producer-actuator/pom.xml → ...sc-stream-kafka-producer-actuator/pom.xml b/...sc-stream-kafka-producer-actuator/pom.xml → ...sc-stream-kafka-producer-actuator/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...kademo/kafkademo/ProducerApplication.java → ...kademo/kafkademo/ProducerApplication.java b/...kademo/kafkademo/ProducerApplication.java → ...kademo/kafkademo/ProducerApplication.java
diff --git a/...afkademo/controller/Demo01Controller.java → ...afkademo/controller/Demo01Controller.java b/...afkademo/controller/Demo01Controller.java → ...afkademo/controller/Demo01Controller.java
diff --git a/...demo/kafkademo/message/Demo01Message.java → ...demo/kafkademo/message/Demo01Message.java b/...demo/kafkademo/message/Demo01Message.java → ...demo/kafkademo/message/Demo01Message.java
diff --git a/...kafkademo/kafkademo/message/MySource.java → ...kafkademo/kafkademo/message/MySource.java b/...kafkademo/kafkademo/message/MySource.java → ...kafkademo/kafkademo/message/MySource.java
diff --git a/...tuator/src/main/resources/application.yml → ...tuator/src/main/resources/application.yml b/...tuator/src/main/resources/application.yml → ...tuator/src/main/resources/application.yml
diff --git a/...11-sc-stream-kafka-producer-batch/pom.xml → ...11-sc-stream-kafka-producer-batch/pom.xml b/...11-sc-stream-kafka-producer-batch/pom.xml → ...11-sc-stream-kafka-producer-batch/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...kademo/kafkademo/ProducerApplication.java → ...kademo/kafkademo/ProducerApplication.java b/...kademo/kafkademo/ProducerApplication.java → ...kademo/kafkademo/ProducerApplication.java
diff --git a/...afkademo/controller/Demo01Controller.java → ...afkademo/controller/Demo01Controller.java b/...afkademo/controller/Demo01Controller.java → ...afkademo/controller/Demo01Controller.java
diff --git a/...demo/kafkademo/message/Demo01Message.java → ...demo/kafkademo/message/Demo01Message.java b/...demo/kafkademo/message/Demo01Message.java → ...demo/kafkademo/message/Demo01Message.java
diff --git a/...kafkademo/kafkademo/message/MySource.java → ...kafkademo/kafkademo/message/MySource.java b/...kafkademo/kafkademo/message/MySource.java → ...kafkademo/kafkademo/message/MySource.java
diff --git a/...-batch/src/main/resources/application.yml → ...-batch/src/main/resources/application.yml b/...-batch/src/main/resources/application.yml → ...-batch/src/main/resources/application.yml
diff --git a/...-11-sc-stream-kafka-producer-demo/pom.xml → ...-11-sc-stream-kafka-producer-demo/pom.xml b/...-11-sc-stream-kafka-producer-demo/pom.xml → ...-11-sc-stream-kafka-producer-demo/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...kademo/kafkademo/ProducerApplication.java → ...kademo/kafkademo/ProducerApplication.java b/...kademo/kafkademo/ProducerApplication.java → ...kademo/kafkademo/ProducerApplication.java
diff --git a/...afkademo/controller/Demo01Controller.java → ...afkademo/controller/Demo01Controller.java b/...afkademo/controller/Demo01Controller.java → ...afkademo/controller/Demo01Controller.java
diff --git a/...demo/kafkademo/message/Demo01Message.java → ...demo/kafkademo/message/Demo01Message.java b/...demo/kafkademo/message/Demo01Message.java → ...demo/kafkademo/message/Demo01Message.java
diff --git a/...kafkademo/kafkademo/message/MySource.java → ...kafkademo/kafkademo/message/MySource.java b/...kafkademo/kafkademo/message/MySource.java → ...kafkademo/kafkademo/message/MySource.java
diff --git a/...r-demo/src/main/resources/application.yml → ...r-demo/src/main/resources/application.yml b/...r-demo/src/main/resources/application.yml → ...r-demo/src/main/resources/application.yml
diff --git a/...tream-kafka-producer-partitioning/pom.xml → ...tream-kafka-producer-partitioning/pom.xml b/...tream-kafka-producer-partitioning/pom.xml → ...tream-kafka-producer-partitioning/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...kademo/kafkademo/ProducerApplication.java → ...kademo/kafkademo/ProducerApplication.java b/...kademo/kafkademo/ProducerApplication.java → ...kademo/kafkademo/ProducerApplication.java
diff --git a/...afkademo/controller/Demo01Controller.java → ...afkademo/controller/Demo01Controller.java b/...afkademo/controller/Demo01Controller.java → ...afkademo/controller/Demo01Controller.java
diff --git a/...demo/kafkademo/message/Demo01Message.java → ...demo/kafkademo/message/Demo01Message.java b/...demo/kafkademo/message/Demo01Message.java → ...demo/kafkademo/message/Demo01Message.java
diff --git a/...kafkademo/kafkademo/message/MySource.java → ...kafkademo/kafkademo/message/MySource.java b/...kafkademo/kafkademo/message/MySource.java → ...kafkademo/kafkademo/message/MySource.java
diff --git a/...ioning/src/main/resources/application.yml → ...ioning/src/main/resources/application.yml b/...ioning/src/main/resources/application.yml → ...ioning/src/main/resources/application.yml
diff --git a/...stream-kafka-producer-transaction/pom.xml → ...stream-kafka-producer-transaction/pom.xml b/...stream-kafka-producer-transaction/pom.xml → ...stream-kafka-producer-transaction/pom.xml
@@ -3,7 +3,7 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>labx-11</artifactId>
+        <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...kademo/kafkademo/ProducerApplication.java → ...kademo/kafkademo/ProducerApplication.java b/...kademo/kafkademo/ProducerApplication.java → ...kademo/kafkademo/ProducerApplication.java
diff --git a/...o/kafkademo/config/TransactionConfig.java → ...o/kafkademo/config/TransactionConfig.java b/...o/kafkademo/config/TransactionConfig.java → ...o/kafkademo/config/TransactionConfig.java
diff --git a/...afkademo/controller/Demo01Controller.java → ...afkademo/controller/Demo01Controller.java b/...afkademo/controller/Demo01Controller.java → ...afkademo/controller/Demo01Controller.java
diff --git a/...demo/kafkademo/message/Demo01Message.java → ...demo/kafkademo/message/Demo01Message.java b/...demo/kafkademo/message/Demo01Message.java → ...demo/kafkademo/message/Demo01Message.java
diff --git a/...kafkademo/kafkademo/message/MySource.java → ...kafkademo/kafkademo/message/MySource.java b/...kafkademo/kafkademo/message/MySource.java → ...kafkademo/kafkademo/message/MySource.java
diff --git a/...action/src/main/resources/application.yml → ...action/src/main/resources/application.yml b/...action/src/main/resources/application.yml → ...action/src/main/resources/application.yml
diff --git a/labx-11/pom.xml → labx-11-spring-cloud-stream-kafka/pom.xml b/labx-11/pom.xml → labx-11-spring-cloud-stream-kafka/pom.xml
@@ -9,7 +9,7 @@
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <artifactId>labx-11</artifactId>
+    <artifactId>labx-11-spring-cloud-stream-kafka</artifactId>
     <packaging>pom</packaging>
 
     <modules>

diff --git a/labx-11/《芋道 Spring Cloud 消息队列 Kafka 入门》.md → ...-kafka/《芋道 Spring Cloud 消息队列 Kafka 入门》.md b/labx-11/《芋道 Spring Cloud 消息队列 Kafka 入门》.md → ...-kafka/《芋道 Spring Cloud 消息队列 Kafka 入门》.md
diff --git a/pom.xml b/pom.xml
@@ -90,8 +90,8 @@
 <!--        <module>labx-07-spring-cloud-alibaba-dubbo</module>-->
 <!--        <module>labx-08-spring-cloud-gateway</module>-->
 <!--        <module>labx-09-spring-cloud-apollo</module>-->
-        <module>labx-10-spring-cloud-stream-rabbitmq</module>
-<!--        <module>labx-11</module>-->
+<!--        <module>labx-10-spring-cloud-stream-rabbitmq</module>-->
+<!--        <module>labx-11-spring-cloud-stream-kafka</module>-->
 <!--        <module>labx-12</module>-->
 <!--        <module>labx-13</module>-->
 <!--        <module>labx-14</module>-->