diff --git a/src/main/resources/application-test.yml b/src/main/resources/application-test.yml
index 1a65574..4bba05a 100644
--- a/src/main/resources/application-test.yml
+++ b/src/main/resources/application-test.yml
@@ -53,7 +53,7 @@ spring:
       connection-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
       use-global-data-source-stat: true
   kafka:
-    bootstrap-servers: 192.168.0.103:9092
+    bootstrap-servers: 192.168.0.156:9093
     producer:
       # 写入失败时，重试次数。当leader节点失效，一个repli节点会替代成为leader节点，此时可能出现写入失败，
       # 当retris为0时，produce不会重复。retirs重发，此时repli节点完全成为leader节点，不会产生消息丢失。
diff --git a/src/test/java/ink/wgink/wggatewaymanage/WgGatewayManageApplicationTests.java b/src/test/java/ink/wgink/wggatewaymanage/WgGatewayManageApplicationTests.java
index 44105c9..4a9ef08 100644
--- a/src/test/java/ink/wgink/wggatewaymanage/WgGatewayManageApplicationTests.java
+++ b/src/test/java/ink/wgink/wggatewaymanage/WgGatewayManageApplicationTests.java
@@ -1,13 +1,25 @@
 package ink.wgink.wggatewaymanage;
 
+import ink.wgink.gatewaymanage.WgGatewayManageApplication;
 import org.junit.jupiter.api.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.junit4.SpringRunner;
 
-@SpringBootTest
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = WgGatewayManageApplication.class)
+@ActiveProfiles("test")
 class WgGatewayManageApplicationTests {
 
+    @Autowired
+    private KafkaTemplate kafkaTemplate;
+
     @Test
     void contextLoads() {
+        kafkaTemplate.send("tableSync", "{\"tableNumber\":\"C0001\",\"uid\":\"123\",\"action\":\"save\",\"data\":{\"case_code\":\"985\",\"case_description\":\"案件描述\"}}");
     }
 
 }