This is an automated email from the ASF dual-hosted git repository.
liuhongyu 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 67bde62990 fix (#6170)
67bde62990 is described below
commit 67bde629907740261cf97ec2a4b1e11edfc3660f
Author: xcsnx <[email protected]>
AuthorDate: Mon Sep 22 11:53:13 2025 +0800
fix (#6170)
Co-authored-by: aias00 <[email protected]>
---
shenyu-e2e/pom.xml | 2 +-
.../shenyu/e2e/testcase/http/DividePluginCases.java | 2 +-
.../e2e/testcase/logging/kafka/DividePluginCases.java | 16 ++++++++--------
3 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/shenyu-e2e/pom.xml b/shenyu-e2e/pom.xml
index e524324212..63debf1bc6 100644
--- a/shenyu-e2e/pom.xml
+++ b/shenyu-e2e/pom.xml
@@ -58,7 +58,7 @@
<guava.version>32.0.0-jre</guava.version>
<commons-collection.verion>4.4</commons-collection.verion>
<websocket.version>1.5.1</websocket.version>
- <kafka-clients.version>3.7.1</kafka-clients.version>
+ <kafka-clients.version>3.9.1</kafka-clients.version>
</properties>
<modules>
diff --git
a/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-http/src/test/java/org/apache/shenyu/e2e/testcase/http/DividePluginCases.java
b/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-http/src/test/java/org/apache/shenyu/e2e/testcase/http/DividePluginCases.java
index b6e3f2aab0..9d3064312d 100644
---
a/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-http/src/test/java/org/apache/shenyu/e2e/testcase/http/DividePluginCases.java
+++
b/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-http/src/test/java/org/apache/shenyu/e2e/testcase/http/DividePluginCases.java
@@ -39,7 +39,7 @@ public class DividePluginCases implements
ShenYuScenarioProvider {
private ShenYuScenarioSpec testDivideHello() {
return ShenYuScenarioSpec.builder()
- .name("http client hello1")
+ .name("http client hello")
.beforeEachSpec(ShenYuBeforeEachSpec.builder()
.checker(exists("/http/order/findById?id=123"))
.build())
diff --git
a/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-logging-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginCases.java
b/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-logging-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginCases.java
index 010c54867f..712ff5f440 100644
---
a/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-logging-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginCases.java
+++
b/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-logging-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginCases.java
@@ -105,7 +105,7 @@ public class DividePluginCases implements
ShenYuScenarioProvider {
try {
// Send request first
request.request(Method.GET,
"/http/order/findById?id=23");
-
+
Properties properties = new
Properties();
properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
properties.put(ConsumerConfig.GROUP_ID_CONFIG, "shenyu-consumer-group");
@@ -115,16 +115,16 @@ public class DividePluginCases implements
ShenYuScenarioProvider {
properties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
properties.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "10000");
properties.put(ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG, "5000");
-
+
try (KafkaConsumer<String, String>
consumer = new KafkaConsumer<>(properties)) {
consumer.subscribe(Arrays.asList(TOPIC));
-
+
Instant start = Instant.now();
// Set timeout to 30 seconds
- while (Duration.between(start,
Instant.now()).getSeconds() < 90) {
+ while (Duration.between(start,
Instant.now()).getSeconds() < 60 * 5) {
ConsumerRecords<String,
String> records = consumer.poll(Duration.ofMillis(1000));
LOG.info("records.count:{}",
records.count());
-
+
for (var record : records) {
String message =
record.value();
LOG.info("kafka
message:{}", message);
@@ -134,17 +134,17 @@ public class DividePluginCases implements
ShenYuScenarioProvider {
break;
}
}
-
+
if (messageFound.get()) {
break;
}
}
-
+
if (!messageFound.get()) {
LOG.error("Timeout waiting for
kafka message");
Assertions.fail("Did not
receive expected message within timeout period");
}
-
+
Assertions.assertTrue(messageFound.get(), "Expected message was not found in
Kafka topic");
}
} catch (Exception e) {
