diff --git a/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatRequestHeader.java b/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatRequestHeader.java index 33062fd4c0..8dd8fbf055 100644 --- a/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatRequestHeader.java +++ b/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatRequestHeader.java @@ -63,7 +63,7 @@ public class HeartbeatRequestHeader extends Header { private String username = "username"; // PASSWD of the requester - private String passwd = "user@123"; + private String passwd = "default"; @Override public Map toMap() { diff --git a/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeader.java b/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeader.java index 7ca214c508..841e79b1af 100644 --- a/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeader.java +++ b/eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeader.java @@ -61,7 +61,7 @@ public class UnRegRequestHeader extends Header { private String username = "username"; // PASSWD of the requester - private String passwd = "user@123"; + private String passwd = "default"; public static UnRegRequestHeader buildHeader(Map headerParam) { HttpConvertsUtils httpConvertsUtils = new HttpConvertsUtils(); diff --git a/eventmesh-connectors/eventmesh-connector-jdbc/src/main/resources/source-config.yml b/eventmesh-connectors/eventmesh-connector-jdbc/src/main/resources/source-config.yml index 6e966029ad..9e2e4a3448 100644 --- a/eventmesh-connectors/eventmesh-connector-jdbc/src/main/resources/source-config.yml +++ b/eventmesh-connectors/eventmesh-connector-jdbc/src/main/resources/source-config.yml @@ -41,7 +41,7 @@ sourceConnectorConfig: hostname: localhost port: 3306 user: root - password: xxxx + password: default initialStatements: connectTimeout: 10 mysqlConfig: diff --git a/eventmesh-operator/README.md b/eventmesh-operator/README.md index 22e4604d61..d67dbefaf8 100644 --- a/eventmesh-operator/README.md +++ b/eventmesh-operator/README.md @@ -59,7 +59,7 @@ connectors.eventmesh-operator.eventmesh/connector-rocketmq created # View the created Service. kubectl get service NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) AGE -runtime-cluster-service ClusterIP 10.109.209.72 10000/TCP 17s +runtime-cluster-service ClusterIP 127.0.0.1 10000/TCP 17s # Delete CR make delete diff --git a/eventmesh-runtime/scripts/client_manage.sh b/eventmesh-runtime/scripts/client_manage.sh index 0913cc58ec..03ac92087d 100644 --- a/eventmesh-runtime/scripts/client_manage.sh +++ b/eventmesh-runtime/scripts/client_manage.sh @@ -16,12 +16,12 @@ # KIND, either express or implied. See the License for the # specific language governing permissions and limitations # under the License. -i_eg="sh client_manage.sh -i 10.255.34.160 24591" +i_eg="sh client_manage.sh -i 127.0.0.1 24591" s_eg="sh client_manage.sh -s 5319" -r_eg="sh client_manage.sh -r 9876 10.255.1.143 10000" +r_eg="sh client_manage.sh -r 9876 127.0.0.1 10000" a_eg="sh client_manage.sh -a" -x_eg="sh client_manage.sh -x 10.255.34.160 24591 10.255.1.143 10000" -y_eg="sh client_manage.sh -y bq-bypass 10.255.1.143 10000" +x_eg="sh client_manage.sh -x 127.0.0.1 24591 127.0.0.1 10000" +y_eg="sh client_manage.sh -y bq-bypass 127.0.0.1 10000" function printEg() { echo "param error." diff --git a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/MessageUtils.java b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/MessageUtils.java index 90c630c709..b20e5d36fd 100644 --- a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/MessageUtils.java +++ b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/MessageUtils.java @@ -203,7 +203,7 @@ public static EventMeshMessage generateRRMsg(String topic, int i) { public static EventMeshMessage generateAsyncEventMsg(String topic, int i) { EventMeshMessage msg = new EventMeshMessage(); msg.setTopic(topic); - msg.getProperties().put("REPLY_TO", "10.36.0.109@ProducerGroup-producerPool-9-access#V1_4_0#CI"); + msg.getProperties().put("REPLY_TO", "127.0.0.1@ProducerGroup-producerPool-9-access#V1_4_0#CI"); msg.getProperties().put("TTL", "30000"); msg.getProperties().put("PROPERTY_MESSAGE_REPLY_TO", "notnull"); msg.setBody("testAsyncMessage" + i); diff --git a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/TCPClient.java b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/TCPClient.java index 5bb2c0c836..f2f6a01bd6 100644 --- a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/TCPClient.java +++ b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/TCPClient.java @@ -58,7 +58,7 @@ public abstract class TCPClient implements Closeable { protected ConcurrentHashMap contexts = new ConcurrentHashMap<>(); - protected String host = "10.255.34.120"; + protected String host = "127.0.0.1"; protected int port = 10000; diff --git a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/RemotingHelperTest.java b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/RemotingHelperTest.java index 7f0cacc683..b3498a80b2 100644 --- a/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/RemotingHelperTest.java +++ b/eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/RemotingHelperTest.java @@ -36,10 +36,10 @@ public void testExceptionSimpleDesc() { @Test public void testString2SocketAddress() { - String addr = "10.1.1.1:11002"; + String addr = "127.0.0.1:8080"; InetSocketAddress address = (InetSocketAddress) RemotingHelper.string2SocketAddress(addr); Assertions.assertNotNull(address); - Assertions.assertEquals("10.1.1.1:11002", address.getHostString() + ":" + address.getPort()); + Assertions.assertEquals("127.0.0.1:8080", address.getHostString() + ":" + address.getPort()); } @Test diff --git a/eventmesh-sdks/eventmesh-sdk-c/configs/rmb.conf b/eventmesh-sdks/eventmesh-sdk-c/configs/rmb.conf index b30682f8ff..8295ebf163 100644 --- a/eventmesh-sdks/eventmesh-sdk-c/configs/rmb.conf +++ b/eventmesh-sdks/eventmesh-sdk-c/configs/rmb.conf @@ -20,7 +20,7 @@ consumerDcn A00 orgId 99996 localIdc A wemq_user wemq -wemq_passwd wemq@123 +wemq_passwd default #log configure logFile sub @@ -51,9 +51,9 @@ ReqGslSwitch 0 wemqUseHttpCfg 1 configCenterIp 10.255.34.57 configCenterPort 8090 -configCenterAddrMulti 172.22.1.82:8090 +configCenterAddrMulti 127.0.0.1:8090 #connect directly to access when: wemqUseHttpCfg 0 -wemqProxyIp 172.22.0.51 +wemqProxyIp 127.0.0.1 wemqProxyPort 10000 # tlsOnoff：控制与eventmesh的tcp连接是否开启tls # 0: 不开启（默认） diff --git a/eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/EventMeshTestUtils.java b/eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/EventMeshTestUtils.java index dbd3e7233b..dd59233467 100644 --- a/eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/EventMeshTestUtils.java +++ b/eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/EventMeshTestUtils.java @@ -111,7 +111,7 @@ public static EventMeshMessage generateSyncRRMqMsg() { private static EventMeshMessage generateAsyncRRMqMsg() { EventMeshMessage mqMsg = new EventMeshMessage(); mqMsg.setTopic(TOPIC_PRX_SyncSubscribeTest); - mqMsg.getProperties().put("REPLY_TO", "10.36.0.109@ProducerGroup-producerPool-9-access#V1_4_0#CI"); + mqMsg.getProperties().put("REPLY_TO", "127.0.0.1@ProducerGroup-producerPool-9-access#V1_4_0#CI"); mqMsg.getProperties().put("TTL", "300000"); mqMsg.getProperties().put("PROPERTY_MESSAGE_REPLY_TO", "notnull"); mqMsg.setBody("testAsyncRR"); @@ -121,7 +121,7 @@ private static EventMeshMessage generateAsyncRRMqMsg() { private static EventMeshMessage generateAsyncEventMqMsg() { EventMeshMessage mqMsg = new EventMeshMessage(); mqMsg.setTopic(TOPIC_PRX_WQ2ClientUniCast); - mqMsg.getProperties().put("REPLY_TO", "10.36.0.109@ProducerGroup-producerPool-9-access#V1_4_0#CI"); + mqMsg.getProperties().put("REPLY_TO", "127.0.0.1@ProducerGroup-producerPool-9-access#V1_4_0#CI"); mqMsg.getProperties().put("TTL", "30000"); mqMsg.getProperties().put("PROPERTY_MESSAGE_REPLY_TO", "notnull"); mqMsg.setBody("testAsyncMessage"); @@ -131,7 +131,7 @@ private static EventMeshMessage generateAsyncEventMqMsg() { public static EventMeshMessage generateBroadcastMqMsg() { EventMeshMessage mqMsg = new EventMeshMessage(); mqMsg.setTopic(TOPIC_PRX_WQ2ClientBroadCast); - mqMsg.getProperties().put("REPLY_TO", "10.36.0.109@ProducerGroup-producerPool-9-access#V1_4_0#CI"); + mqMsg.getProperties().put("REPLY_TO", "127.0.0.1@ProducerGroup-producerPool-9-access#V1_4_0#CI"); mqMsg.getProperties().put("TTL", "30000"); mqMsg.getProperties().put("PROPERTY_MESSAGE_REPLY_TO", "notnull"); mqMsg.setBody("testAsyncMessage");