[type:feat]add kafka logging e2e test

apache · Jan 19, 2025 · b626c85 · b626c85
1 parent 8a715ae
commit b626c85
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ng-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginTest.java b/...ng-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginTest.java
@@ -117,7 +117,7 @@ void setup(final AdminClient adminClient, final GatewayClient gatewayClient) thr
         reqBody.put("sort", "180");
         reqBody.put("namespaceId", Constants.SYS_DEFAULT_NAMESPACE_NAMESPACE_ID);
         reqBody.put("config",
-                "{\"topic\":\"shenyu-access-logging\",\"namesrvAddr\":\"shenyu-kafka:9092\",\"sampleRate\":\"1\",\"maxResponseBody\":524288,\"maxRequestBody\":524288,\"compressAlg\":\"none\"}");
+                "{\"topic\":\"shenyu-access-logging\",\"namesrvAddr\":\"localhost:31092\",\"sampleRate\":\"1\",\"maxResponseBody\":524288,\"maxRequestBody\":524288,\"compressAlg\":\"none\"}");
         adminClient.changePluginStatus("1801816010882822171", reqBody);
         Map<String, Integer> plugins = gatewayClient.getPlugins();
         LOG.info("shenyu e2e plugin list ={}", plugins);