You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@eventmesh.apache.org by "slowpao (via GitHub)" <gi...@apache.org> on 2023/03/02 15:09:56 UTC
[GitHub] [incubator-eventmesh] slowpao commented on a diff in pull request #3324: [ISSUE #3323] Unsubscribe from a single topic
slowpao commented on code in PR #3324:
URL: https://github.com/apache/incubator-eventmesh/pull/3324#discussion_r1123253824
##########
eventmesh-runtime/conf/eventmesh.properties:
##########
@@ -17,15 +17,15 @@
###############################EVNETMESH-runtime ENV#################################
eventMesh.server.idc=DEFAULT
eventMesh.server.env=PRD
-eventMesh.server.provide.protocols=HTTP,TCP,GRPC
+eventMesh.server.provide.protocols=HTTP,TCP
Review Comment:
Used during testing, can be ignored
##########
eventmesh-runtime/conf/eventmesh.properties:
##########
@@ -17,15 +17,15 @@
###############################EVNETMESH-runtime ENV#################################
eventMesh.server.idc=DEFAULT
eventMesh.server.env=PRD
-eventMesh.server.provide.protocols=HTTP,TCP,GRPC
+eventMesh.server.provide.protocols=HTTP,TCP
eventMesh.server.cluster=COMMON
eventMesh.server.name=EVENTMESH-runtime
eventMesh.sysid=0000
eventMesh.server.http.port=10105
eventMesh.server.grpc.port=10205
########################## eventMesh tcp configuration ############################
eventMesh.server.tcp.enabled=true
-eventMesh.server.tcp.port=10002
+eventMesh.server.tcp.port=10102
eventMesh.server.tcp.readerIdleSeconds=120
Review Comment:
Used during testing, can be ignored
##########
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/test/java/org/apache/eventmesh/connector/pulsar/config/ClientConfigurationTest.java:
##########
@@ -43,8 +43,8 @@ public void getConfigWhenPulsarProducerInit() {
}
private void assertConfig(ClientConfiguration config) {
- Assert.assertEquals(config.getServiceAddr(), "127.0.0.1:6650");
- Assert.assertEquals(config.getAuthPlugin(), "authPlugin-success!!!");
- Assert.assertEquals(config.getAuthParams(), "authParams-success!!!");
+ Assert.assertEquals(config.getServiceAddr(), null);
+ Assert.assertEquals(config.getAuthPlugin(), null);
+ Assert.assertEquals(config.getAuthParams(), null);
}
Review Comment:
ok,I will repair it as soon as possible
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org