From 7aed640e930ac80a4925a03785553b11040846ff Mon Sep 17 00:00:00 2001
From: YunaiV <>
Date: Sun, 28 Jun 2020 19:23:38 +0800
Subject: [PATCH] =?UTF-8?q?Spring=20Cloud=20Stream=20Kafka=20=E5=85=A5?=
 =?UTF-8?q?=E9=97=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 README.md                                                     | 4 ++--
 .../labx-11-sc-stream-kafka-consumer-ack/pom.xml              | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-consumer-actuator/pom.xml         | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-consumer-batch/pom.xml            | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-consumer-broadcasting/pom.xml     | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-consumer-concurrency/pom.xml      | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-consumer-demo/pom.xml             | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-consumer-error-handler/pom.xml    | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-consumer-filter/pom.xml           | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-consumer-partitioning/pom.xml     | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-consumer-retry/pom.xml            | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-consumer-transaction/pom.xml      | 2 +-
 .../labx11/kafkademo/consumerdemo/ConsumerApplication.java    | 0
 .../kafkademo/consumerdemo/listener/Demo01Consumer.java       | 0
 .../labx11/kafkademo/consumerdemo/listener/MySink.java        | 0
 .../labx11/kafkademo/consumerdemo/message/Demo01Message.java  | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-producer-actuator/pom.xml         | 2 +-
 .../labx11/kafkademo/kafkademo/ProducerApplication.java       | 0
 .../kafkademo/kafkademo/controller/Demo01Controller.java      | 0
 .../labx11/kafkademo/kafkademo/message/Demo01Message.java     | 0
 .../labx11/kafkademo/kafkademo/message/MySource.java          | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-producer-batch/pom.xml            | 2 +-
 .../labx11/kafkademo/kafkademo/ProducerApplication.java       | 0
 .../kafkademo/kafkademo/controller/Demo01Controller.java      | 0
 .../labx11/kafkademo/kafkademo/message/Demo01Message.java     | 0
 .../labx11/kafkademo/kafkademo/message/MySource.java          | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-producer-demo/pom.xml             | 2 +-
 .../labx11/kafkademo/kafkademo/ProducerApplication.java       | 0
 .../kafkademo/kafkademo/controller/Demo01Controller.java      | 0
 .../labx11/kafkademo/kafkademo/message/Demo01Message.java     | 0
 .../labx11/kafkademo/kafkademo/message/MySource.java          | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-producer-partitioning/pom.xml     | 2 +-
 .../labx11/kafkademo/kafkademo/ProducerApplication.java       | 0
 .../kafkademo/kafkademo/controller/Demo01Controller.java      | 0
 .../labx11/kafkademo/kafkademo/message/Demo01Message.java     | 0
 .../labx11/kafkademo/kafkademo/message/MySource.java          | 0
 .../src/main/resources/application.yml                        | 0
 .../labx-11-sc-stream-kafka-producer-transaction/pom.xml      | 2 +-
 .../labx11/kafkademo/kafkademo/ProducerApplication.java       | 0
 .../labx11/kafkademo/kafkademo/config/TransactionConfig.java  | 0
 .../kafkademo/kafkademo/controller/Demo01Controller.java      | 0
 .../labx11/kafkademo/kafkademo/message/Demo01Message.java     | 0
 .../labx11/kafkademo/kafkademo/message/MySource.java          | 0
 .../src/main/resources/application.yml                        | 0
 {labx-11 => labx-11-spring-cloud-stream-kafka}/pom.xml        | 2 +-
 .../《芋道 Spring Cloud 消息队列 Kafka 入门》.md              | 0
 pom.xml                                                       | 4 ++--
 101 files changed, 21 insertions(+), 21 deletions(-)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-ack/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-ack/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-actuator/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-actuator/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-batch/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-batch/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-broadcasting/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-concurrency/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-concurrency/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-demo/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-demo/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-error-handler/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-error-handler/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-filter/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-filter/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-partitioning/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-partitioning/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-retry/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-retry/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-transaction/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-consumer-transaction/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-actuator/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-actuator/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-batch/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-batch/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-demo/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-demo/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-partitioning/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-partitioning/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-transaction/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/config/TransactionConfig.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/labx-11-sc-stream-kafka-producer-transaction/src/main/resources/application.yml (100%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/pom.xml (97%)
 rename {labx-11 => labx-11-spring-cloud-stream-kafka}/《芋道 Spring Cloud 消息队列 Kafka 入门》.md (100%)

diff --git a/README.md b/README.md
index 8f1b02a3..aea573d8 100644
--- 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/labx-11/labx-11-sc-stream-kafka-consumer-ack/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-ack/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/pom.xml
index d29b1fd8..4e534fdc 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-ack/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-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/labx-11/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-ack/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-ack/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-ack/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-actuator/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-actuator/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/pom.xml
index 9b2b4202..8ec8a3c7 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-actuator/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-11-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/labx-11/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-actuator/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-actuator/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-actuator/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-batch/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-batch/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/pom.xml
index 1dc128fd..e271914a 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-batch/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-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/labx-11/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-batch/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-batch/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-batch/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/pom.xml
index 5a3cbaaa..87796349 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-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/labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-broadcasting/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-concurrency/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-concurrency/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/pom.xml
index 3eea5acd..d18d6425 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-concurrency/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-11-sc-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/labx-11/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-concurrency/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-concurrency/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-concurrency/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-demo/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-demo/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/pom.xml
index 021d5a0d..bcfbe5fd 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-demo/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-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/labx-11/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-demo/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-demo/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-demo/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-error-handler/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-error-handler/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/pom.xml
index f977b8d4..f4896978 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-error-handler/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-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/labx-11/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-error-handler/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-error-handler/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-error-handler/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-filter/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-filter/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/pom.xml
index 1533110a..c9e91d88 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-filter/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-11-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/labx-11/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-filter/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-filter/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-filter/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-partitioning/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-partitioning/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/pom.xml
index 438af790..bc46ac2b 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-partitioning/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-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/labx-11/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-partitioning/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-partitioning/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-partitioning/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-retry/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-retry/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/pom.xml
index d9cd9498..dbbe8829 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-retry/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-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/labx-11/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-retry/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-retry/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-retry/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-transaction/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-consumer-transaction/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/pom.xml
index 7f165c64..1171410c 100644
--- a/labx-11/labx-11-sc-stream-kafka-consumer-transaction/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-11-sc-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/labx-11/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/ConsumerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/Demo01Consumer.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/listener/MySink.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/consumerdemo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-consumer-transaction/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-consumer-transaction/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-consumer-transaction/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-actuator/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-producer-actuator/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/pom.xml
index 179381ad..e0631da4 100644
--- a/labx-11/labx-11-sc-stream-kafka-producer-actuator/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-11-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/labx-11/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-actuator/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-actuator/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-actuator/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-batch/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-producer-batch/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/pom.xml
index 579473ee..013fc309 100644
--- a/labx-11/labx-11-sc-stream-kafka-producer-batch/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-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/labx-11/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-batch/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-batch/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-batch/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-demo/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-producer-demo/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/pom.xml
index 451b14ca..41620906 100644
--- a/labx-11/labx-11-sc-stream-kafka-producer-demo/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-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/labx-11/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-demo/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-demo/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-demo/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-partitioning/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-producer-partitioning/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/pom.xml
index 877a2cb7..74cce3f3 100644
--- a/labx-11/labx-11-sc-stream-kafka-producer-partitioning/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-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/labx-11/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-partitioning/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-partitioning/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-partitioning/src/main/resources/application.yml
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-transaction/pom.xml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/pom.xml
similarity index 97%
rename from labx-11/labx-11-sc-stream-kafka-producer-transaction/pom.xml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/pom.xml
index cdebac52..adf0827b 100644
--- a/labx-11/labx-11-sc-stream-kafka-producer-transaction/pom.xml
+++ b/labx-11-spring-cloud-stream-kafka/labx-11-sc-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/labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/ProducerApplication.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/config/TransactionConfig.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/config/TransactionConfig.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/config/TransactionConfig.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/config/TransactionConfig.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/controller/Demo01Controller.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/Demo01Message.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/java/cn/iocoder/springcloud/labx11/kafkademo/kafkademo/message/MySource.java
diff --git a/labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/resources/application.yml b/labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/resources/application.yml
similarity index 100%
rename from labx-11/labx-11-sc-stream-kafka-producer-transaction/src/main/resources/application.yml
rename to labx-11-spring-cloud-stream-kafka/labx-11-sc-stream-kafka-producer-transaction/src/main/resources/application.yml
diff --git a/labx-11/pom.xml b/labx-11-spring-cloud-stream-kafka/pom.xml
similarity index 97%
rename from labx-11/pom.xml
rename to labx-11-spring-cloud-stream-kafka/pom.xml
index 1d92ae6a..53d41ca6 100644
--- a/labx-11/pom.xml
+++ b/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 b/labx-11-spring-cloud-stream-kafka/《芋道 Spring Cloud 消息队列 Kafka 入门》.md
similarity index 100%
rename from labx-11/《芋道 Spring Cloud 消息队列 Kafka 入门》.md
rename to labx-11-spring-cloud-stream-kafka/《芋道 Spring Cloud 消息队列 Kafka 入门》.md
diff --git a/pom.xml b/pom.xml
index 49715f9b..82b7c59d 100644
--- 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>-->