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 @@
4.0.0
- labx-19-sc-bus-rabbitmq-demo-listener-actuator
+ labx-19-sc-bus-kafka-demo-listener-actuator
1.8
@@ -48,10 +48,10 @@
spring-boot-starter-web
-
+
org.springframework.cloud
- spring-cloud-starter-bus-amqp
+ spring-cloud-starter-bus-kafka
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 @@
4.0.0
- labx-19-sc-bus-rabbitmq-demo-publisher-actuator
+ labx-19-sc-bus-kafka-demo-publisher-actuator
1.8
@@ -48,10 +48,10 @@
spring-boot-starter-web
-
+
org.springframework.cloud
- spring-cloud-starter-bus-amqp
+ spring-cloud-starter-bus-kafka
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 @@
labx-19-sc-bus-kafka-demo-publisher
labx-19-sc-bus-kafka-demo-listener
-
-
+ labx-19-sc-bus-kafka-demo-listener-actuator
+ labx-19-sc-bus-kafka-demo-publisher-actuator