This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new b94841245 [ISSUE #5162] Remove and replace sensitive information
involved in code (#5163)
b94841245 is described below
commit b94841245604fc4256aa7971eb96e1a1cf828d2b
Author: mike_xwm <[email protected]>
AuthorDate: Fri Jan 10 14:30:19 2025 +0800
[ISSUE #5162] Remove and replace sensitive information involved in code
(#5163)
---
.../protocol/http/header/client/HeartbeatRequestHeader.java | 2 +-
.../common/protocol/http/header/client/UnRegRequestHeader.java | 2 +-
.../eventmesh-connector-jdbc/src/main/resources/source-config.yml | 2 +-
eventmesh-operator/README.md | 2 +-
eventmesh-runtime/scripts/client_manage.sh | 8 ++++----
.../org/apache/eventmesh/runtime/client/common/MessageUtils.java | 2 +-
.../org/apache/eventmesh/runtime/client/common/TCPClient.java | 2 +-
.../org/apache/eventmesh/runtime/util/RemotingHelperTest.java | 4 ++--
eventmesh-sdks/eventmesh-sdk-c/configs/rmb.conf | 6 +++---
.../apache/eventmesh/client/tcp/common/EventMeshTestUtils.java | 6 +++---
10 files changed, 18 insertions(+), 18 deletions(-)
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 33062fd4c..8dd8fbf05 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<String, Object> 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 7ca214c50..841e79b1a 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<String, Object>
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 6e966029a..9e2e4a344 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 22e4604d6..d67dbefaf 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 <none> 10000/TCP
17s
+runtime-cluster-service ClusterIP 127.0.0.1 <none> 10000/TCP 17s
# Delete CR
make delete
diff --git a/eventmesh-runtime/scripts/client_manage.sh
b/eventmesh-runtime/scripts/client_manage.sh
index 0913cc58e..03ac92087 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 90c630c70..b20e5d36f 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 class MessageUtils {
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 5bb2c0c83..f2f6a01bd 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<Object, RequestContext> 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 7f0cacc68..b3498a80b 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 class RemotingHelperTest {
@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 b30682f8f..8295ebf16 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 dbd3e7233..dd5923346 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 class EventMeshTestUtils {
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 @@ public class EventMeshTestUtils {
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 @@ public class EventMeshTestUtils {
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");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
