From d05ec0584311db8a0240a507a93ac3a50fa2df1e Mon Sep 17 00:00:00 2001 From: wanggeng <450292408@qq.com> Date: Wed, 22 Dec 2021 21:05:29 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/resources/application-test.yml | 2 +- .../WgGatewayManageApplicationTests.java | 14 +++++++++++++- 2 files changed, 14 insertions(+), 2 deletions(-) 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\":\"案件描述\"}}"); } }