[shenyu] branch master updated: [type:test] fix Kafka test takes too long. (#4308)

[xiaoyu]

This is an automated email from the ASF dual-hosted git repository.

xiaoyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shenyu.git


The following commit(s) were added to refs/heads/master by this push:
     new 47875108f [type:test] fix Kafka test takes too long. (#4308)
47875108f is described below

commit 47875108f3bc15ab86700e3efd7048a5f99c13be
Author: yunlongn <yunlo...@outlook.com>
AuthorDate: Wed Jan 11 19:09:16 2023 +0800

    [type:test] fix Kafka test takes too long. (#4308)
    
    * [type:test] fix Kafka test takes too long.
    
    * [type:test] fix Kafka test takes too long.
    
    * [type:test] fix Kafka test takes too long.
    
    * [type:test] fix Kafka test takes too long.
    
    * [type:test] fix Kafka test takes too long.
    
    * [type:test] fix Kafka test takes too long.
    
    Co-authored-by: xiaoyu <xia...@apache.org>
---
 .../kafka/handler/LoggingKafkaPluginDataHandlerTest.java |  2 +-
 .../logging/kafka/kafka/KafkaLogCollectClientTest.java   | 16 +++++++++++-----
 2 files changed, 12 insertions(+), 6 deletions(-)

diff --git 
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/handler/LoggingKafkaPluginDataHandlerTest.java
 
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/handler/LoggingKafkaPluginDataHandlerTest.java
index 684e0ab02..dbf82d757 100644
--- 
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/handler/LoggingKafkaPluginDataHandlerTest.java
+++ 
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/handler/LoggingKafkaPluginDataHandlerTest.java
@@ -57,7 +57,7 @@ public class LoggingKafkaPluginDataHandlerTest {
         List<ConditionData> list = new ArrayList<>();
         list.add(conditionData);
         selectorData.setConditionList(list);
-        pluginData.setEnabled(true);
+        pluginData.setEnabled(false);
         pluginData.setConfig("{\"topic\":\"test\", 
\"namesrvAddr\":\"localhost:8082\"}");
     }
 
diff --git 
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/kafka/KafkaLogCollectClientTest.java
 
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/kafka/KafkaLogCollectClientTest.java
index 452119483..0584cdb6b 100644
--- 
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/kafka/KafkaLogCollectClientTest.java
+++ 
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/kafka/KafkaLogCollectClientTest.java
@@ -17,6 +17,7 @@
 
 package org.apache.shenyu.plugin.logging.kafka.kafka;
 
+import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.shenyu.common.dto.PluginData;
 import org.apache.shenyu.common.utils.GsonUtils;
 import org.apache.shenyu.plugin.logging.common.entity.ShenyuRequestLog;
@@ -26,9 +27,12 @@ import org.junit.Ignore;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.mockito.MockedConstruction;
 
 import java.lang.reflect.Field;
 
+import static org.mockito.Mockito.mockConstruction;
+
 /**
  * The Test Case For RocketMQLogCollectClient.
  */
@@ -56,10 +60,12 @@ public class KafkaLogCollectClientTest {
     @Test
     @Ignore
     public void testInitClient() throws NoSuchFieldException, 
IllegalAccessException {
-        kafkaLogCollectClient.initClient(globalLogConfig);
-        Field field = 
kafkaLogCollectClient.getClass().getDeclaredField("topic");
-        field.setAccessible(true);
-        Assertions.assertEquals(field.get(kafkaLogCollectClient), 
"shenyu-access-logging");
-        kafkaLogCollectClient.close();
+        try (MockedConstruction<KafkaProducer> construction = 
mockConstruction(KafkaProducer.class)) {
+            kafkaLogCollectClient.initClient(globalLogConfig);
+            Field field = 
kafkaLogCollectClient.getClass().getDeclaredField("topic");
+            field.setAccessible(true);
+            Assertions.assertEquals(field.get(kafkaLogCollectClient), 
"shenyu-access-logging");
+            kafkaLogCollectClient.close();
+        }
     }
 }