From 7348e0419dd4bb93b7a3d57f6ad5ea055e940d0e Mon Sep 17 00:00:00 2001
From: YunaiV <>
Date: Thu, 9 Apr 2020 07:50:28 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=20spring=20cloud=20bus=20kaf?=
 =?UTF-8?q?ka=20=E7=A4=BA=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../pom.xml                                              | 6 +++---
 .../labx19}/listenerdemo/ListenerDemoApplication.java    | 0
 .../labx19}/listenerdemo/event/UserRegisterEvent.java    | 0
 .../listenerdemo/listener/UserRegisterListener.java      | 0
 .../src/main/resources/application.yml                   | 9 +++------
 .../pom.xml                                              | 6 +++---
 .../labx19}/publisherdemo/PublisherDemoApplication.java  | 0
 .../labx19}/publisherdemo/controller/DemoController.java | 0
 .../labx19}/publisherdemo/event/UserRegisterEvent.java   | 0
 .../src/main/resources/application.yml                   | 9 +++------
 .../labx19/publisherdemo/controller/DemoController.java  | 1 -
 labx-19/pom.xml                                          | 4 ++--
 12 files changed, 14 insertions(+), 21 deletions(-)
 rename labx-19/{labx-18-sc-bus-rabbitmq-demo-listener-actuator => labx-19-sc-bus-kafka-demo-listener-actuator}/pom.xml (90%)
 rename labx-19/{labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx18 => labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19}/listenerdemo/ListenerDemoApplication.java (100%)
 rename labx-19/{labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx18 => labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19}/listenerdemo/event/UserRegisterEvent.java (100%)
 rename labx-19/{labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx18 => labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19}/listenerdemo/listener/UserRegisterListener.java (100%)
 rename labx-19/{labx-18-sc-bus-rabbitmq-demo-listener-actuator => labx-19-sc-bus-kafka-demo-listener-actuator}/src/main/resources/application.yml (69%)
 rename labx-19/{labx-18-sc-bus-rabbitmq-demo-publisher-actuator => labx-19-sc-bus-kafka-demo-publisher-actuator}/pom.xml (90%)
 rename labx-19/{labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx18 => labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19}/publisherdemo/PublisherDemoApplication.java (100%)
 rename labx-19/{labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx18 => labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19}/publisherdemo/controller/DemoController.java (100%)
 rename labx-19/{labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx18 => labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19}/publisherdemo/event/UserRegisterEvent.java (100%)
 rename labx-19/{labx-18-sc-bus-rabbitmq-demo-publisher-actuator => labx-19-sc-bus-kafka-demo-publisher-actuator}/src/main/resources/application.yml (64%)

diff --git a/labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/pom.xml b/labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/pom.xml
similarity index 90%
rename from labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/pom.xml
rename to labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/pom.xml
index e43c35ec..653b242f 100644
--- a/labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/pom.xml
+++ b/labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/pom.xml
@@ -9,7 +9,7 @@
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <artifactId>labx-19-sc-bus-rabbitmq-demo-listener-actuator</artifactId>
+    <artifactId>labx-19-sc-bus-kafka-demo-listener-actuator</artifactId>
 
     <properties>
         <maven.compiler.target>1.8</maven.compiler.target>
@@ -48,10 +48,10 @@
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
 
-        <!-- 引入基于 RabbitMQ 的 Spring Cloud Bus 的实现的依赖，并实现对其的自动配置 -->
+        <!-- 引入基于 Kafka 的 Spring Cloud Bus 的实现的依赖，并实现对其的自动配置 -->
         <dependency>
             <groupId>org.springframework.cloud</groupId>
-            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+            <artifactId>spring-cloud-starter-bus-kafka</artifactId>
         </dependency>
 
         <!-- 实现对 Actuator 的自动化配置 -->
diff --git a/labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx18/listenerdemo/ListenerDemoApplication.java b/labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19/listenerdemo/ListenerDemoApplication.java
similarity index 100%
rename from labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx18/listenerdemo/ListenerDemoApplication.java
rename to labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19/listenerdemo/ListenerDemoApplication.java
diff --git a/labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx18/listenerdemo/event/UserRegisterEvent.java b/labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19/listenerdemo/event/UserRegisterEvent.java
similarity index 100%
rename from labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx18/listenerdemo/event/UserRegisterEvent.java
rename to labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19/listenerdemo/event/UserRegisterEvent.java
diff --git a/labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx18/listenerdemo/listener/UserRegisterListener.java b/labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19/listenerdemo/listener/UserRegisterListener.java
similarity index 100%
rename from labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx18/listenerdemo/listener/UserRegisterListener.java
rename to labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/java/cn/iocoder/springcloud/labx19/listenerdemo/listener/UserRegisterListener.java
diff --git a/labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/resources/application.yml b/labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/resources/application.yml
similarity index 69%
rename from labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/resources/application.yml
rename to labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/resources/application.yml
index 05743d70..9077fbeb 100644
--- a/labx-19/labx-18-sc-bus-rabbitmq-demo-listener-actuator/src/main/resources/application.yml
+++ b/labx-19/labx-19-sc-bus-kafka-demo-listener-actuator/src/main/resources/application.yml
@@ -2,12 +2,9 @@ spring:
   application:
     name: listener-demo
 
-  # RabbitMQ 相关配置项
-  rabbitmq:
-    host: localhost
-    port: 5672
-    username: guest
-    password: guest
+  # Kafka 配置项，对应 KafkaProperties 配置类
+  kafka:
+    bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址，可以设置多个，以逗号分隔
 
 server:
   port: 18080 # 随机端口，方便启动多个消费者
diff --git a/labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/pom.xml b/labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/pom.xml
similarity index 90%
rename from labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/pom.xml
rename to labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/pom.xml
index cbe48476..bedeab16 100644
--- a/labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/pom.xml
+++ b/labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/pom.xml
@@ -9,7 +9,7 @@
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <artifactId>labx-19-sc-bus-rabbitmq-demo-publisher-actuator</artifactId>
+    <artifactId>labx-19-sc-bus-kafka-demo-publisher-actuator</artifactId>
 
     <properties>
         <maven.compiler.target>1.8</maven.compiler.target>
@@ -48,10 +48,10 @@
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
 
-        <!-- 引入基于 RabbitMQ 的 Spring Cloud Bus 的实现的依赖，并实现对其的自动配置 -->
+        <!-- 引入基于 Kafka 的 Spring Cloud Bus 的实现的依赖，并实现对其的自动配置 -->
         <dependency>
             <groupId>org.springframework.cloud</groupId>
-            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+            <artifactId>spring-cloud-starter-bus-kafka</artifactId>
         </dependency>
 
         <!-- 实现对 Actuator 的自动化配置 -->
diff --git a/labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx18/publisherdemo/PublisherDemoApplication.java b/labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/PublisherDemoApplication.java
similarity index 100%
rename from labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx18/publisherdemo/PublisherDemoApplication.java
rename to labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/PublisherDemoApplication.java
diff --git a/labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx18/publisherdemo/controller/DemoController.java b/labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/controller/DemoController.java
similarity index 100%
rename from labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx18/publisherdemo/controller/DemoController.java
rename to labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/controller/DemoController.java
diff --git a/labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx18/publisherdemo/event/UserRegisterEvent.java b/labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/event/UserRegisterEvent.java
similarity index 100%
rename from labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx18/publisherdemo/event/UserRegisterEvent.java
rename to labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/event/UserRegisterEvent.java
diff --git a/labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/resources/application.yml b/labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/resources/application.yml
similarity index 64%
rename from labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/resources/application.yml
rename to labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/resources/application.yml
index 1ea2852d..8cef4a3f 100644
--- a/labx-19/labx-18-sc-bus-rabbitmq-demo-publisher-actuator/src/main/resources/application.yml
+++ b/labx-19/labx-19-sc-bus-kafka-demo-publisher-actuator/src/main/resources/application.yml
@@ -2,12 +2,9 @@ spring:
   application:
     name: publisher-demo
 
-  # RabbitMQ 相关配置项
-  rabbitmq:
-    host: localhost
-    port: 5672
-    username: guest
-    password: guest
+  # Kafka 配置项，对应 KafkaProperties 配置类
+  kafka:
+    bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址，可以设置多个，以逗号分隔
 
 management:
   endpoints:
diff --git a/labx-19/labx-19-sc-bus-kafka-demo-publisher/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/controller/DemoController.java b/labx-19/labx-19-sc-bus-kafka-demo-publisher/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/controller/DemoController.java
index ddcb938f..21148a95 100644
--- a/labx-19/labx-19-sc-bus-kafka-demo-publisher/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/controller/DemoController.java
+++ b/labx-19/labx-19-sc-bus-kafka-demo-publisher/src/main/java/cn/iocoder/springcloud/labx19/publisherdemo/controller/DemoController.java
@@ -33,5 +33,4 @@ public class DemoController {
         return "success";
     }
 
-
 }
diff --git a/labx-19/pom.xml b/labx-19/pom.xml
index 1c75ccfe..5f6cc732 100644
--- a/labx-19/pom.xml
+++ b/labx-19/pom.xml
@@ -15,8 +15,8 @@
         <module>labx-19-sc-bus-kafka-demo-publisher</module>
         <module>labx-19-sc-bus-kafka-demo-listener</module>
 
-<!--        <module>labx-19-sc-bus-rabbitmq-demo-listener-actuator</module>-->
-<!--        <module>labx-19-sc-bus-rabbitmq-demo-publisher-actuator</module>-->
+        <module>labx-19-sc-bus-kafka-demo-listener-actuator</module>
+        <module>labx-19-sc-bus-kafka-demo-publisher-actuator</module>
     </modules>