This is an automated email from the ASF dual-hosted git repository.
xingfudeshi pushed a commit to branch gsoc-2025-meta-registry
in repository https://gitbox.apache.org/repos/asf/incubator-seata.git
The following commit(s) were added to refs/heads/gsoc-2025-meta-registry by
this push:
new c7e813d199 optimize: metadata discovery support for eureka (#7748)
c7e813d199 is described below
commit c7e813d199f8016bc323d7f97192ffcf3a7c45fe
Author: YoWuwuuuw <[email protected]>
AuthorDate: Tue Nov 18 15:45:58 2025 +0800
optimize: metadata discovery support for eureka (#7748)
---
.../seata/common/metadata/ServiceInstance.java | 6 +
.../seata/common/metadata/ServiceInstanceTest.java | 11 +
.../eureka/CustomEurekaInstanceConfig.java | 25 ++
.../registry/eureka/EurekaRegistryServiceImpl.java | 26 ++-
.../eureka/CustomEurekaInstanceConfigTest.java | 14 ++
...java => EurekaRegistryServiceImplMockTest.java} | 2 +-
.../eureka/EurekaRegistryServiceImplTest.java | 251 +++++----------------
.../src/test/resources/file.conf | 25 ++
8 files changed, 153 insertions(+), 207 deletions(-)
diff --git
a/common/src/main/java/org/apache/seata/common/metadata/ServiceInstance.java
b/common/src/main/java/org/apache/seata/common/metadata/ServiceInstance.java
index d92ff12a4a..ef9e1a7421 100644
--- a/common/src/main/java/org/apache/seata/common/metadata/ServiceInstance.java
+++ b/common/src/main/java/org/apache/seata/common/metadata/ServiceInstance.java
@@ -39,6 +39,12 @@ public class ServiceInstance {
this.metadata = metadata;
}
+ public ServiceInstance(Instance instance) {
+ this.address = new InetSocketAddress(
+ instance.getTransaction().getHost(),
instance.getTransaction().getPort());
+ this.metadata = instance.getMetadata();
+ }
+
public ServiceInstance(InetSocketAddress address) {
this.address = address;
}
diff --git
a/common/src/test/java/org/apache/seata/common/metadata/ServiceInstanceTest.java
b/common/src/test/java/org/apache/seata/common/metadata/ServiceInstanceTest.java
index 0c8596c0c2..9aa055267e 100644
---
a/common/src/test/java/org/apache/seata/common/metadata/ServiceInstanceTest.java
+++
b/common/src/test/java/org/apache/seata/common/metadata/ServiceInstanceTest.java
@@ -48,6 +48,17 @@ public class ServiceInstanceTest {
Instance instance = Instance.getInstance();
instance.setTransaction(new Node.Endpoint("127.0.0.1", 8093));
+
+ ServiceInstance instance2 = new
ServiceInstance(Instance.getInstance());
+
+ assertEquals(
+ Instance.getInstance().getTransaction().getHost(),
+ instance2.getAddress().getAddress().getHostAddress());
+ assertEquals(
+ Instance.getInstance().getTransaction().getPort(),
+ instance2.getAddress().getPort());
+
+ instance.setTransaction(null); // clean up after test
}
@Test
diff --git
a/discovery/seata-discovery-eureka/src/main/java/org/apache/seata/discovery/registry/eureka/CustomEurekaInstanceConfig.java
b/discovery/seata-discovery-eureka/src/main/java/org/apache/seata/discovery/registry/eureka/CustomEurekaInstanceConfig.java
index 6f23a83493..5bd2f383c5 100644
---
a/discovery/seata-discovery-eureka/src/main/java/org/apache/seata/discovery/registry/eureka/CustomEurekaInstanceConfig.java
+++
b/discovery/seata-discovery-eureka/src/main/java/org/apache/seata/discovery/registry/eureka/CustomEurekaInstanceConfig.java
@@ -20,6 +20,9 @@ import com.netflix.appinfo.EurekaInstanceConfig;
import com.netflix.appinfo.MyDataCenterInstanceConfig;
import org.apache.seata.common.util.StringUtils;
+import java.util.HashMap;
+import java.util.Map;
+
/**
* override MyDataCenterInstanceConfig for set value,
* eg: instanceId \ipAddress \ applicationName...
@@ -29,6 +32,7 @@ public class CustomEurekaInstanceConfig extends
MyDataCenterInstanceConfig imple
private String instanceId;
private String ipAddress;
private int port = -1;
+ private Map<String, Object> metadata = new HashMap<>();
@Override
public String getInstanceId() {
@@ -67,6 +71,27 @@ public class CustomEurekaInstanceConfig extends
MyDataCenterInstanceConfig imple
return this.getIpAddress();
}
+ public Map<String, Object> getMetadata() {
+ return metadata;
+ }
+
+ public void setMetadata(Map<String, Object> metadata) {
+ this.metadata = metadata;
+ }
+
+ @Override
+ public Map<String, String> getMetadataMap() {
+ Map<String, String> stringMap = new HashMap<>();
+ if (metadata != null) {
+ for (Map.Entry<String, Object> entry : metadata.entrySet()) {
+ if (entry.getValue() != null) {
+ stringMap.put(entry.getKey(),
String.valueOf(entry.getValue()));
+ }
+ }
+ }
+ return stringMap;
+ }
+
public void setInstanceId(String instanceId) {
this.instanceId = instanceId;
}
diff --git
a/discovery/seata-discovery-eureka/src/main/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImpl.java
b/discovery/seata-discovery-eureka/src/main/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImpl.java
index 19aa7097b2..5bdfbdd4b4 100644
---
a/discovery/seata-discovery-eureka/src/main/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImpl.java
+++
b/discovery/seata-discovery-eureka/src/main/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImpl.java
@@ -40,7 +40,9 @@ import org.slf4j.LoggerFactory;
import java.net.InetSocketAddress;
import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
+import java.util.Map;
import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
@@ -102,6 +104,8 @@ public class EurekaRegistryServiceImpl implements
RegistryService<EurekaEventLis
instanceConfig.setPort(address.getPort());
instanceConfig.setApplicationName(getApplicationName());
instanceConfig.setInstanceId(getInstanceId());
+ instanceConfig.setMetadata(instance.getMetadata());
+
getEurekaClient(true);
applicationInfoManager.setInstanceStatus(InstanceInfo.InstanceStatus.UP);
}
@@ -168,14 +172,20 @@ public class EurekaRegistryServiceImpl implements
RegistryService<EurekaEventLis
if (application == null ||
CollectionUtils.isEmpty(application.getInstances())) {
LOGGER.info("refresh cluster success,but cluster empty! cluster
name:{}", clusterName);
} else {
- List<ServiceInstance> onlineInstanceList =
-
ServiceInstance.convertToServiceInstanceList(application.getInstances().stream()
- .filter(instance ->
InstanceInfo.InstanceStatus.UP.equals(instance.getStatus())
- && instance.getIPAddr() != null
- && instance.getPort() > 0
- && instance.getPort() < 0xFFFF)
- .map(instance -> new
InetSocketAddress(instance.getIPAddr(), instance.getPort()))
- .collect(Collectors.toList()));
+ List<ServiceInstance> onlineInstanceList =
application.getInstances().stream()
+ .filter(instance ->
InstanceInfo.InstanceStatus.UP.equals(instance.getStatus())
+ && instance.getIPAddr() != null
+ && instance.getPort() > 0
+ && instance.getPort() < 0xFFFF)
+ .map(instance -> {
+ InetSocketAddress address = new
InetSocketAddress(instance.getIPAddr(), instance.getPort());
+ Map<String, Object> metadata = new HashMap<>();
+ if (instance.getMetadata() != null) {
+ metadata.putAll(instance.getMetadata());
+ }
+ return new ServiceInstance(address, metadata);
+ })
+ .collect(Collectors.toList());
CLUSTER_INSTANCE_MAP.put(clusterName, onlineInstanceList);
removeOfflineAddressesIfNecessary(transactionServiceGroup,
clusterName, onlineInstanceList);
diff --git
a/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/CustomEurekaInstanceConfigTest.java
b/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/CustomEurekaInstanceConfigTest.java
index 3fdb188ae3..73841130e9 100644
---
a/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/CustomEurekaInstanceConfigTest.java
+++
b/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/CustomEurekaInstanceConfigTest.java
@@ -21,6 +21,8 @@ import org.junit.jupiter.api.Test;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
+import java.util.HashMap;
+import java.util.Map;
import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -97,6 +99,18 @@ public class CustomEurekaInstanceConfigTest {
assertEquals(ipAddress, config.getHostName(false));
}
+ @Test
+ void testSetMetadata() {
+ Map<String, Object> metadata = new HashMap<>();
+ metadata.put("key1", "value1");
+ metadata.put("key2", 123);
+
+ config.setMetadata(metadata);
+ assertEquals(2, config.getMetadata().size());
+ assertEquals("value1", config.getMetadata().get("key1"));
+ assertEquals(123, config.getMetadata().get("key2"));
+ }
+
private Object getConfigString(String method)
throws NoSuchMethodException, IllegalAccessException,
InvocationTargetException {
Class<?> grandparentClass =
config.getClass().getSuperclass().getSuperclass();
diff --git
a/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImplTest.java
b/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImplMockTest.java
similarity index 99%
copy from
discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImplTest.java
copy to
discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImplMockTest.java
index 77b1d68f24..f2463263d8 100644
---
a/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImplTest.java
+++
b/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImplMockTest.java
@@ -44,7 +44,7 @@ import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
-public class EurekaRegistryServiceImplTest {
+public class EurekaRegistryServiceImplMockTest {
private EurekaClient mockEurekaClient;
private ApplicationInfoManager mockAppInfoManager;
diff --git
a/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImplTest.java
b/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImplTest.java
index 77b1d68f24..d42a459000 100644
---
a/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImplTest.java
+++
b/discovery/seata-discovery-eureka/src/test/java/org/apache/seata/discovery/registry/eureka/EurekaRegistryServiceImplTest.java
@@ -16,226 +16,81 @@
*/
package org.apache.seata.discovery.registry.eureka;
-import com.netflix.appinfo.ApplicationInfoManager;
-import com.netflix.appinfo.InstanceInfo;
-import com.netflix.discovery.EurekaClient;
-import com.netflix.discovery.EurekaEventListener;
-import com.netflix.discovery.shared.Application;
import org.apache.seata.common.metadata.ServiceInstance;
-import org.apache.seata.config.Configuration;
-import org.apache.seata.config.ConfigurationFactory;
-import org.apache.seata.config.exception.ConfigNotFoundException;
+import org.apache.seata.discovery.registry.RegistryProvider;
+import org.apache.seata.discovery.registry.RegistryService;
import org.junit.jupiter.api.AfterAll;
-import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
-import org.mockito.MockedStatic;
-import java.lang.reflect.Field;
import java.net.InetSocketAddress;
-import java.util.Collections;
+import java.util.HashMap;
import java.util.List;
-import java.util.concurrent.ConcurrentMap;
+import java.util.Map;
+import java.util.ServiceLoader;
-import static org.mockito.Mockito.any;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.mockStatic;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.when;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+/**
+ * EurekaRegistryServiceImpl integration test
+ */
+@Disabled
public class EurekaRegistryServiceImplTest {
- private EurekaClient mockEurekaClient;
- private ApplicationInfoManager mockAppInfoManager;
- private Application mockApplication;
- private InstanceInfo mockInstanceInfo;
- private EurekaRegistryServiceImpl registryService;
- EurekaEventListener mockEventListener;
-
- @BeforeEach
- public void setUp() throws Exception {
+ private static RegistryService registryService;
- mockEurekaClient = mock(EurekaClient.class);
- mockAppInfoManager = mock(ApplicationInfoManager.class);
- mockApplication = mock(Application.class);
- mockInstanceInfo = mock(InstanceInfo.class);
- mockEventListener = mock(EurekaEventListener.class);
-
- resetSingleton();
- registryService = EurekaRegistryServiceImpl.getInstance();
- setStaticField(EurekaRegistryServiceImpl.class, "eurekaClient",
mockEurekaClient);
- setStaticField(EurekaRegistryServiceImpl.class,
"applicationInfoManager", mockAppInfoManager);
+ @BeforeAll
+ public static void setUp() throws Exception {
+ ServiceLoader<RegistryProvider> providers =
ServiceLoader.load(RegistryProvider.class);
+ RegistryProvider provider = providers.iterator().next();
+ registryService = provider.provide();
}
@AfterAll
public static void tearDown() throws Exception {
- resetSingleton();
- }
-
- private static void resetSingleton() throws Exception {
- // Reset singleton and static fields
- setStaticField(EurekaRegistryServiceImpl.class, "instance", null);
- setStaticField(EurekaRegistryServiceImpl.class,
"applicationInfoManager", null);
- setStaticField(EurekaRegistryServiceImpl.class, "eurekaClient", null);
- setStaticField(EurekaRegistryServiceImpl.class, "instanceConfig",
null);
- clearStaticMap(EurekaRegistryServiceImpl.class,
"LISTENER_SERVICE_MAP");
- clearStaticMap(EurekaRegistryServiceImpl.class,
"CLUSTER_INSTANCE_MAP");
- clearStaticMap(EurekaRegistryServiceImpl.class, "CLUSTER_LOCK");
- }
-
- @Test
- public void testGetInstance() {
- EurekaRegistryServiceImpl instance1 =
EurekaRegistryServiceImpl.getInstance();
- EurekaRegistryServiceImpl instance2 =
EurekaRegistryServiceImpl.getInstance();
- Assertions.assertEquals(instance1, instance2);
- }
-
- @Test
- public void testRegister() throws Exception {
- InetSocketAddress address = new InetSocketAddress("127.0.0.1", 8091);
- registryService.register(new ServiceInstance(address));
- CustomEurekaInstanceConfig instanceConfig = getInstanceConfig();
- Assertions.assertEquals("127.0.0.1", instanceConfig.getIpAddress());
- Assertions.assertEquals("default", instanceConfig.getAppname());
-
verify(mockAppInfoManager).setInstanceStatus(InstanceInfo.InstanceStatus.UP);
- }
-
- @Test
- void testRegisterWhenEurekaClientIsNull() throws Exception {
- setStaticField(EurekaRegistryServiceImpl.class, "eurekaClient", null);
- InetSocketAddress address = new InetSocketAddress("127.0.0.1", 8091);
- registryService.register(new ServiceInstance(address));
- verify(mockAppInfoManager, times(0)).setInstanceStatus(any());
- }
-
- @Test
- void testSubscribe() throws Exception {
- String testCluster = "TEST_CLUSTER";
- registryService.subscribe(testCluster, mockEventListener);
-
- // Verify that the listener is added to LISTENER_SERVICE_MAP
- ConcurrentMap<String, List<EurekaEventListener>> listenerMap =
getStaticListenerMap();
- Assertions.assertTrue(listenerMap.containsKey(testCluster));
-
Assertions.assertTrue(listenerMap.get(testCluster).contains(mockEventListener));
-
- // Verify that the EurekaClient has registered the listener
- verify(mockEurekaClient,
times(1)).registerEventListener(mockEventListener);
- }
-
- @Test
- void testUnsubscribe() throws Exception {
- String testCluster = "TEST_CLUSTER";
- registryService.subscribe(testCluster, mockEventListener);
- registryService.unsubscribe(testCluster, mockEventListener);
-
- // Verify that the listener is removed from LISTENER_SERVICE_MAP
- ConcurrentMap<String, List<EurekaEventListener>> listenerMap =
getStaticListenerMap();
- Assertions.assertFalse(
- listenerMap.getOrDefault(testCluster,
Collections.emptyList()).contains(mockEventListener));
-
- // Verify that the EurekaClient has deregistered the listener
- verify(mockEurekaClient,
times(1)).unregisterEventListener(mockEventListener);
- }
-
- @Test
- void testUnsubscribeWhenEurekaClientIsNull() throws Exception {
- setStaticField(EurekaRegistryServiceImpl.class, "eurekaClient", null);
- registryService.unsubscribe("TEST_CLUSTER", mockEventListener);
- verify(mockEurekaClient, times(0)).unregisterEventListener(any());
- }
-
- @Test
- void testUnsubscribeWithNoExistingListeners() throws Exception {
- String testCluster = "NON_EXISTENT_CLUSTER";
- registryService.unsubscribe(testCluster, mockEventListener);
- verify(mockEurekaClient).unregisterEventListener(any());
- }
-
- @Test
- public void testUnregister() throws Exception {
- registryService.unregister(new ServiceInstance(new
InetSocketAddress("127.0.0.1", 8091)));
-
verify(mockAppInfoManager).setInstanceStatus(InstanceInfo.InstanceStatus.DOWN);
- }
-
- @Test
- public void testLookup() throws Exception {
- Configuration mockConfig = mock(Configuration.class);
-
when(mockConfig.getConfig("service.vgroupMapping.test-group")).thenReturn("TEST-CLUSTER");
-
- try (MockedStatic<ConfigurationFactory> mockedFactory =
mockStatic(ConfigurationFactory.class)) {
-
mockedFactory.when(ConfigurationFactory::getInstance).thenReturn(mockConfig);
-
- // Mock Eureka to return the application instance
-
when(mockEurekaClient.getApplication("TEST-CLUSTER")).thenReturn(mockApplication);
-
when(mockApplication.getInstances()).thenReturn(Collections.singletonList(mockInstanceInfo));
-
when(mockInstanceInfo.getStatus()).thenReturn(InstanceInfo.InstanceStatus.UP);
- when(mockInstanceInfo.getIPAddr()).thenReturn("192.168.1.1");
- when(mockInstanceInfo.getPort()).thenReturn(8091);
-
- List<ServiceInstance> instances =
registryService.lookup("test-group");
-
- // Verify whether the transactionServiceGroup is set correctly
- Field serviceGroupField =
EurekaRegistryServiceImpl.class.getDeclaredField("transactionServiceGroup");
- serviceGroupField.setAccessible(true);
- String actualServiceGroup = (String)
serviceGroupField.get(registryService);
- Assertions.assertEquals("test-group", actualServiceGroup);
- Assertions.assertNotNull(instances);
- Assertions.assertEquals(1, instances.size());
- Assertions.assertEquals(
- new InetSocketAddress("192.168.1.1", 8091),
instances.get(0).getAddress());
+ if (registryService != null) {
+ registryService.close();
}
}
@Test
- void testLookUpWithNoClusterName() {
- Configuration mockConfig = mock(Configuration.class);
-
when(mockConfig.getConfig("service.vgroupMapping.test-group")).thenReturn(null);
- try (MockedStatic<ConfigurationFactory> mockedFactory =
mockStatic(ConfigurationFactory.class)) {
-
mockedFactory.when(ConfigurationFactory::getInstance).thenReturn(mockConfig);
- Assertions.assertThrows(ConfigNotFoundException.class, () -> {
- registryService.lookup("test-group");
- });
+ public void testMetadataRegistrationAndDiscovery() throws Exception {
+ Map<String, Object> metadata = new HashMap<>();
+ metadata.put("version", "1.0.0");
+ metadata.put("environment", "test");
+ metadata.put("weight", 100);
+
+ ServiceInstance instance = new ServiceInstance(new
InetSocketAddress("127.0.0.1", 8094), metadata);
+ registryService.register(instance);
+
+ Thread.sleep(8000);
+
+ List<ServiceInstance> instances = null;
+ // Wait for the Eureka client's local cache to sync to avoid the first
query being empty.
+ for (int i = 0; i < 10; i++) {
+ instances = registryService.lookup("default_tx_group");
+ if (instances != null && !instances.isEmpty()) {
+ break;
+ }
+ Thread.sleep(2000);
}
- }
-
- @Test
- public void testClose() throws Exception {
- registryService.close();
- verify(mockEurekaClient).shutdown();
- Assertions.assertNull(getStaticField(EurekaRegistryServiceImpl.class,
"eurekaClient"));
- Assertions.assertNull(getStaticField(EurekaRegistryServiceImpl.class,
"applicationInfoManager"));
- }
- // Helper method: Set static fields via reflection
- private static void setStaticField(Class<?> clazz, String fieldName,
Object value) throws Exception {
- Field field = clazz.getDeclaredField(fieldName);
- field.setAccessible(true);
- field.set(null, value);
- }
-
- // Helper method: Get the value of a static field
- @SuppressWarnings("unchecked")
- private static <T> T getStaticField(Class<?> clazz, String fieldName)
throws Exception {
- Field field = clazz.getDeclaredField(fieldName);
- field.setAccessible(true);
- return (T) field.get(null);
- }
+ assertNotNull(instances);
+ assertFalse(instances.isEmpty());
- private static void clearStaticMap(Class<?> clazz, String fieldName)
throws Exception {
- Field field = clazz.getDeclaredField(fieldName);
- field.setAccessible(true);
- ((ConcurrentMap<?, ?>) field.get(null)).clear();
- }
-
- private CustomEurekaInstanceConfig getInstanceConfig() throws Exception {
- return getStaticField(EurekaRegistryServiceImpl.class,
"instanceConfig");
- }
+ ServiceInstance foundInstance = instances.stream()
+ .filter(inst ->
inst.getAddress().equals(instance.getAddress()))
+ .findFirst()
+ .orElse(null);
- @SuppressWarnings("unchecked")
- private static ConcurrentMap<String, List<EurekaEventListener>>
getStaticListenerMap() throws Exception {
- Field field =
EurekaRegistryServiceImpl.class.getDeclaredField("LISTENER_SERVICE_MAP");
- field.setAccessible(true);
- return (ConcurrentMap<String, List<EurekaEventListener>>)
field.get(null);
+ assertNotNull(foundInstance);
+ Map<String, Object> foundMetadata = foundInstance.getMetadata();
+ assertNotNull(foundMetadata);
+ assertEquals("1.0.0", String.valueOf(foundMetadata.get("version")));
+ assertEquals("test", String.valueOf(foundMetadata.get("environment")));
+ assertEquals("100", String.valueOf(foundMetadata.get("weight")));
}
}
diff --git a/discovery/seata-discovery-eureka/src/test/resources/file.conf
b/discovery/seata-discovery-eureka/src/test/resources/file.conf
new file mode 100644
index 0000000000..46c3e0401c
--- /dev/null
+++ b/discovery/seata-discovery-eureka/src/test/resources/file.conf
@@ -0,0 +1,25 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+service {
+ #transaction service group mapping
+ vgroupMapping.default_tx_group = "default"
+ #only support when registry.type=file, please don't set multiple addresses
+ default.grouplist = "127.0.0.1:8091"
+ #disable seata
+ disableGlobalTransaction = false
+}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
