[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2023-10-07 Thread GitBox 


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user RongtongJin (triggered by RongtongJin).

Head commit for run:
c36bb78e850129b9db40adc5b0e1b9bfd5c8fd2e / shriVATSA54 
<116296557+shrivats...@users.noreply.github.com>
[ISSUE 7313]  Enhancement Optimization Method name (#7420)

* Enhancment/method_name/#7313/

* Enhancment/method_name/#7313/

* Enhancment/method_name/#7313/

Report URL: https://github.com/apache/rocketmq/actions/runs/6439661758

With regards,
GitHub Actions via GitBox

[I] boost.log冲突 [rocketmq-client-cpp]

2023-10-07 Thread via GitHub 


kqbi opened a new issue, #458:
URL: https://github.com/apache/rocketmq-client-cpp/issues/458

   1. Please describe the issue you observed:
   
   
因为要集成rocketmq，就编译了rocketmq-client-cpp的2.2.0版本的动态库librocketmq.so，这其中依赖boost-1.58.0并使用了boost.log的静态库，然后我的主程序使用了boost-1.83.0版本的boost.log的动态库，然后我的主程序一旦集成librocketmq.so就会在librocketmq库中调用boost.log的时候崩溃，具体崩溃在boost::log::v2s_mt_posix::sinks::text_file_backend::scan_for_files函数中，
   初步怀疑是boost.log 中有些全局调用冲突了，这个怎么解决？
   
   2. Please tell us about your environment:
   
- What is your OS?
   
   centos7.9
   
- What is your client version?
   
   2.2.0
   
- What is your RocketMQ version?
   5.1.3
   


-- 
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: commits-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[I] Multiple sinks cannot be implemented [rocketmq-streams]

2023-10-07 Thread via GitHub 


380828801 opened a new issue, #311:
URL: https://github.com/apache/rocketmq-streams/issues/311

StreamBuilder builder = new StreamBuilder("wordCount");
   
   RStream source = builder.source("stream-topic-1", total 
-> {
   String value = new String(total, StandardCharsets.UTF_8);
   JSONObject jsonObject = JSON.parseObject(value);
   return new Pair<>(null, jsonObject);
   });
   
   source.print();
   source.sink("stream-topic-sink",new KVJsonSerializer<>());
   
   TopologyBuilder topologyBuilder = builder.build();
   
   
   In TopologyBuilder, public  Processor build(String topicName) is 
executed in node order and cannot implement multiple sinks. The above code can 
only execute the first sink.


-- 
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: commits-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[PR] fix: Map's concurrency issues [rocketmq-client-go]

2023-10-07 Thread via GitHub 


anrror opened a new pull request, #1100:
URL: https://github.com/apache/rocketmq-client-go/pull/1100

   …e sync.Map
   
   ## What is the purpose of the change
   
   Map will fail during concurrency。  
When using ‘go’ (code:/vebchmark/nessage.go:225  go func... ). the map 
must add lock or replace with sync.Map 
It has length usage, so I can't use the sync.Map
   
   bug:
   goroutine 841 [running]:
   runtime.throw({0x2235be1?, 0xc000bac480?})
/usr/local/go/src/runtime/panic.go:992 +0x71 fp=0xc001a9b868 
sp=0xc001a9b838 pc=0x438731
   runtime.mapassign_faststr(0xc000518d40?, 0x1dc5040?, {0xc000c18b10, 0x16})
/usr/local/go/src/runtime/map_faststr.go:212 +0x39c fp=0xc001a9b8d0 
sp=0xc001a9b868 pc=0x4135fc
   
github.com/apache/rocketmq-client-go/v2/consumer.(*pushConsumer).Subscribe(0xc000281740,
 {0xc000c18b10?, 0x4?}, {{0x0?, 0x40d645?}, {0x0?, 0x4?}}, 0xc0005a2320)

/home/app/go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2/consumer/push_consumer.go:305
 +0x1fb fp=0xc001a9b960 sp=0xc001a9b8d0 pc=0x82ab5b
   ## Brief changelog
   
  Map's concurrency issues
   
   ## Verifying this change
   
   
   
   Follow this checklist to help us incorporate your contribution quickly and 
easily. Notice, `it would be helpful if you could finish the following 5 
checklist(the last one is not necessary)before request the community to review 
your PR`.
   
   - [x] Make sure there is a [Github 
issue](https://github.com/apache/rocketmq/issues) filed for the change (usually 
before you start working on it). Trivial changes like typos do not require a 
Github issue. Your pull request should address just this issue, without pulling 
in other changes - one PR resolves one issue. 
   - [x] Format the pull request title like `[ISSUE #123] Fix UnknownException 
when host config not exist`. Each commit in the pull request should have a 
meaningful subject line and body.
   - [x] Write a pull request description that is detailed enough to understand 
what the pull request does, how, and why.
   - [x] Write necessary unit-test(over 80% coverage) to verify your logic 
correction, more mock a little better when a cross-module dependency exists.
   - [ ] If this contribution is large, please file an [Apache Individual 
Contributor License Agreement](http://www.apache.org/licenses/#clas).
   


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Re: [PR] [ISSUE #6808] Fixed network bugs and merged networkutil code [rocketmq]

2023-10-07 Thread via GitHub 


zekai-li commented on PR #6811:
URL: https://github.com/apache/rocketmq/pull/6811#issuecomment-1751663865

   @RongtongJin Please check it.


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Re: [I] Optimize the grafana dashboard. [rocketmq-exporter]

2023-10-07 Thread via GitHub 


chinaboy007 commented on issue #93:
URL: 
https://github.com/apache/rocketmq-exporter/issues/93#issuecomment-1751671448

   > > 能分享下模板吗？
   > 
   > 这个 https://github.com/xxd763795151/rocketmq-monitor
   
   非常感谢！


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Re: [I] boost.log冲突 [rocketmq-client-cpp]

2023-10-07 Thread via GitHub 


ifplusor commented on issue #458:
URL: 
https://github.com/apache/rocketmq-client-cpp/issues/458#issuecomment-1751677664

   You can modify `CMakeLists.txt` and link shared libraries of boost.


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Re: [PR] [ISSUE #7306] Create system topic subscription when autoCreateSubscriptionGroup is false. [rocketmq]

2023-10-07 Thread via GitHub 


echooymxq commented on PR #7384:
URL: https://github.com/apache/rocketmq/pull/7384#issuecomment-1751740650

   @drpmma Help review it. 🙏


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Re: [I] Broker may lost messages in extreme condition [rocketmq]

2023-10-07 Thread via GitHub 


github-actions[bot] commented on issue #5235:
URL: https://github.com/apache/rocketmq/issues/5235#issuecomment-1751870926

   This issue was closed because it has been inactive for 3 days since being 
marked as stale.


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Re: [I] Broker may lost messages in extreme condition [rocketmq]

2023-10-07 Thread via GitHub 


github-actions[bot] closed issue #5235: Broker may lost messages in extreme 
condition
URL: https://github.com/apache/rocketmq/issues/5235


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Re: [PR] [ISSUE #7315] Adding Rejected Policy Parameters to the ThreadPoolMonitor Construction Method [rocketmq]

2023-10-07 Thread via GitHub 


RapperCL commented on PR #7316:
URL: https://github.com/apache/rocketmq/pull/7316#issuecomment-1751894658

   > @RapperCL Please resolve the conflict.
   
   
   
   > > @RapperCL Please resolve the conflict.
   > 
   > 👌
   
   @lizhimins  @mxsm   hey， please review it 


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Re: [PR] [ISSUE #7321] Refector NettyRemotingAbstract with unify future implementation [rocketmq]

2023-10-07 Thread via GitHub 


drpmma merged PR #7322:
URL: https://github.com/apache/rocketmq/pull/7322


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Re: [I] [Enhancement] [ISSUE #7296] [TASK 1] Refector NettyRemotingAbstract with unify future implementation. [rocketmq]

2023-10-07 Thread via GitHub 


drpmma closed issue #7321: [Enhancement] [ISSUE #7296] [TASK 1] Refector 
NettyRemotingAbstract with unify future implementation.
URL: https://github.com/apache/rocketmq/issues/7321


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[rocketmq] branch develop updated: [ISSUE #7321] Refector NettyRemotingAbstract with unify future implementation (#7322)

2023-10-07 Thread zhouxzhan 
This is an automated email from the ASF dual-hosted git repository.

zhouxzhan pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
 new 84156084a4 [ISSUE #7321] Refector NettyRemotingAbstract with unify 
future implementation (#7322)
84156084a4 is described below

commit 84156084a4c5228e1d2fe21e068fff330bbc40d1
Author: Zhouxiang Zhan 
AuthorDate: Sun Oct 8 11:13:25 2023 +0800

[ISSUE #7321] Refector NettyRemotingAbstract with unify future 
implementation (#7322)

* Refector NettyRemotingAbstract

* Add invoke with future method

* Deprecate InvokeCallback#operationComplete

* Add operationSuccess and operationException for InvokeCallback

* fix unit test

* fix unit test

* Keep InvokeCallback#operationComplete

* Optimize invokeAsyncImpl operationComplete

* Add unit test for NettyRemotingClient

* fix checkstyle
---
 .../apache/rocketmq/broker/out/BrokerOuterAPI.java | 147 ++
 .../apache/rocketmq/client/impl/MQAdminImpl.java   |  71 ++---
 .../rocketmq/client/impl/MQClientAPIImpl.java  | 239 
 .../client/impl/mqclient/MQClientAPIExt.java   | 309 +
 .../rocketmq/client/impl/MQClientAPIImplTest.java  |  12 +-
 .../proxy/remoting/RemotingProtocolServer.java |  22 +-
 .../proxy/service/mqclient/MQClientAPIExtTest.java |  97 +++
 .../apache/rocketmq/remoting/InvokeCallback.java   |  15 +
 .../apache/rocketmq/remoting/RemotingClient.java   |  27 +-
 .../remoting/netty/NettyRemotingAbstract.java  | 123 +---
 .../remoting/netty/NettyRemotingClient.java|  33 ++-
 .../rocketmq/remoting/netty/ResponseFuture.java|  15 +
 .../rocketmq/remoting/rpc/RpcClientImpl.java   |  29 +-
 .../rocketmq/remoting/RemotingServerTest.java  |  22 +-
 .../rocketmq/remoting/netty/MockChannel.java   |  21 +-
 .../remoting/netty/MockChannelPromise.java | 191 +
 .../remoting/netty/NettyRemotingAbstractTest.java  |  54 +++-
 .../remoting/netty/NettyRemotingClientTest.java| 185 +++-
 18 files changed, 1029 insertions(+), 583 deletions(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java 
b/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
index 9dfb8127d6..6fde48dd99 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
@@ -73,6 +73,7 @@ import 
org.apache.rocketmq.remoting.exception.RemotingTimeoutException;
 import org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException;
 import org.apache.rocketmq.remoting.netty.NettyClientConfig;
 import org.apache.rocketmq.remoting.netty.NettyRemotingClient;
+import org.apache.rocketmq.remoting.netty.ResponseFuture;
 import org.apache.rocketmq.remoting.protocol.BrokerSyncInfo;
 import org.apache.rocketmq.remoting.protocol.DataVersion;
 import org.apache.rocketmq.remoting.protocol.RemotingCommand;
@@ -107,6 +108,8 @@ import 
org.apache.rocketmq.remoting.protocol.header.SendMessageRequestHeader;
 import org.apache.rocketmq.remoting.protocol.header.SendMessageRequestHeaderV2;
 import org.apache.rocketmq.remoting.protocol.header.SendMessageResponseHeader;
 import 
org.apache.rocketmq.remoting.protocol.header.controller.AlterSyncStateSetRequestHeader;
+import 
org.apache.rocketmq.remoting.protocol.header.controller.ElectMasterRequestHeader;
+import 
org.apache.rocketmq.remoting.protocol.header.controller.ElectMasterResponseHeader;
 import 
org.apache.rocketmq.remoting.protocol.header.controller.GetMetaDataResponseHeader;
 import 
org.apache.rocketmq.remoting.protocol.header.controller.GetReplicaInfoRequestHeader;
 import 
org.apache.rocketmq.remoting.protocol.header.controller.GetReplicaInfoResponseHeader;
@@ -124,8 +127,6 @@ import 
org.apache.rocketmq.remoting.protocol.header.namesrv.RegisterBrokerReques
 import 
org.apache.rocketmq.remoting.protocol.header.namesrv.RegisterBrokerResponseHeader;
 import 
org.apache.rocketmq.remoting.protocol.header.namesrv.RegisterTopicRequestHeader;
 import 
org.apache.rocketmq.remoting.protocol.header.namesrv.UnRegisterBrokerRequestHeader;
-import 
org.apache.rocketmq.remoting.protocol.header.controller.ElectMasterRequestHeader;
-import 
org.apache.rocketmq.remoting.protocol.header.controller.ElectMasterResponseHeader;
 import org.apache.rocketmq.remoting.protocol.heartbeat.SubscriptionData;
 import org.apache.rocketmq.remoting.protocol.namesrv.RegisterBrokerResult;
 import org.apache.rocketmq.remoting.protocol.route.BrokerData;
@@ -151,7 +152,6 @@ public class BrokerOuterAPI {
 private final RpcClient rpcClient;
 private String nameSrvAddr = null;
 
-
 public BrokerOuterAPI(final NettyClientConfig nettyClientConfig) {
 this(nettyClientConfig, new

[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" is working again!

2023-10-07 Thread GitBox 


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
succeeded.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
84156084a4c5228e1d2fe21e068fff330bbc40d1 / Zhouxiang Zhan 
[ISSUE #7321] Refector NettyRemotingAbstract with unify future implementation 
(#7322)

* Refector NettyRemotingAbstract

* Add invoke with future method

* Deprecate InvokeCallback#operationComplete

* Add operationSuccess and operationException for InvokeCallback

* fix unit test

* fix unit test

* Keep InvokeCallback#operationComplete

* Optimize invokeAsyncImpl operationComplete

* Add unit test for NettyRemotingClient

* fix checkstyle

Report URL: https://github.com/apache/rocketmq/actions/runs/6445197585

With regards,
GitHub Actions via GitBox

[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2023-10-07 Thread GitBox 


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
84156084a4c5228e1d2fe21e068fff330bbc40d1 / Zhouxiang Zhan 
[ISSUE #7321] Refector NettyRemotingAbstract with unify future implementation 
(#7322)

* Refector NettyRemotingAbstract

* Add invoke with future method

* Deprecate InvokeCallback#operationComplete

* Add operationSuccess and operationException for InvokeCallback

* fix unit test

* fix unit test

* Keep InvokeCallback#operationComplete

* Optimize invokeAsyncImpl operationComplete

* Add unit test for NettyRemotingClient

* fix checkstyle

Report URL: https://github.com/apache/rocketmq/actions/runs/6445197590

With regards,
GitHub Actions via GitBox

[GH] (rocketmq): Workflow run "Coverage" failed!

2023-10-07 Thread GitBox 


The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
b636ae3c2404663f4c36a814ef191edcd45c7714 / zhouxiang 

Add enableHeartbeatChannelEventListener for ClientConfig

Report URL: https://github.com/apache/rocketmq/actions/runs/6445351357

With regards,
GitHub Actions via GitBox

Re: [I] [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题 [rocketmq-clients]

2023-10-07 Thread via GitHub 


francisoliverlee commented on issue #606:
URL: 
https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1751913907

   try "127.0.0.1:8080;127.0.2:8081"


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2023-10-07 Thread GitBox 


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
b636ae3c2404663f4c36a814ef191edcd45c7714 / zhouxiang 

Add enableHeartbeatChannelEventListener for ClientConfig

Report URL: https://github.com/apache/rocketmq/actions/runs/6445351355

With regards,
GitHub Actions via GitBox

Re: [PR] [ISSUE #7300] jRaft-Controller Implemention [rocketmq]

2023-10-07 Thread via GitHub 


joeCarf commented on code in PR #7301:
URL: https://github.com/apache/rocketmq/pull/7301#discussion_r1349626480


##
example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java:
##
@@ -30,7 +30,7 @@ public class Producer {
 /**
  * The number of produced messages.
  */
-public static final int MESSAGE_COUNT = 1000;
+public static final int MESSAGE_COUNT = 10;

Review Comment:
   why change this file?



-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Re: [I] [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题 [rocketmq-clients]

2023-10-07 Thread via GitHub 


0902horn commented on issue #606:
URL: 
https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1751928921

   > try "127.0.0.1:8080;127.0.2:8081"
   
   That's right. 
   See 
https://github.com/apache/rocketmq-clients/blob/16bc4a8c61717b038cfb4b17de00bd3969e91290/cpp/source/rocketmq/ClientImpl.cpp#L73


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GH] (rocketmq): Workflow run "Coverage" failed!

2023-10-07 Thread GitBox 


The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
b636ae3c2404663f4c36a814ef191edcd45c7714 / zhouxiang 

Add enableHeartbeatChannelEventListener for ClientConfig

Report URL: https://github.com/apache/rocketmq/actions/runs/6445351357

With regards,
GitHub Actions via GitBox

Re: [PR] replace nlog with Microsoft.Extensions.Logging [rocketmq-clients]

2023-10-07 Thread via GitHub 


lizhanhui merged PR #596:
URL: https://github.com/apache/rocketmq-clients/pull/596


-- 
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: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[rocketmq-clients] branch master updated: replace nlog with Microsoft.Extensions.Logging (#596)

2023-10-07 Thread lizhanhui 
This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
 new 17bd443b replace nlog with Microsoft.Extensions.Logging (#596)
17bd443b is described below

commit 17bd443b438df9aa0e1d9d92d38973d8466e6f7c
Author: EventHorizon <772552...@qq.com>
AuthorDate: Sun Oct 8 14:07:34 2023 +0800

replace nlog with Microsoft.Extensions.Logging (#596)

* replace nlog with Microsoft.Extensions.Logging

* fix md format

* use nlog as default LoggerFactory and remove useless nlog configuration 
file

-

Co-authored-by: Event Horizon <772552754@qq.com>
---
 csharp/README-CN.md| 16 +-
 csharp/README.md   | 15 --
 csharp/examples/ProducerBenchmark.cs   |  6 +--
 csharp/examples/ProducerDelayMessageExample.cs |  6 +--
 csharp/examples/ProducerFifoMessageExample.cs  |  7 ++-
 csharp/examples/ProducerNormalMessageExample.cs|  6 +--
 .../examples/ProducerTransactionMessageExample.cs  |  8 +--
 csharp/examples/QuickStart.cs  |  9 
 csharp/examples/SimpleConsumerExample.cs   | 10 ++--
 csharp/examples/examples.csproj|  3 ++
 csharp/rocketmq-client-csharp/Client.cs| 60 +++---
 .../ClientLoggerInterceptor.cs |  8 +--
 csharp/rocketmq-client-csharp/ClientMeter.cs   |  8 +--
 .../rocketmq-client-csharp/ClientMeterManager.cs   | 10 ++--
 csharp/rocketmq-client-csharp/MessageView.cs   |  9 ++--
 csharp/rocketmq-client-csharp/MqLogManager.cs  | 58 -
 csharp/rocketmq-client-csharp/Producer.cs  | 42 +++
 .../rocketmq-client-csharp/PublishingSettings.cs   |  6 +--
 csharp/rocketmq-client-csharp/RpcClient.cs | 10 ++--
 csharp/rocketmq-client-csharp/Session.cs   | 14 ++---
 csharp/rocketmq-client-csharp/SimpleConsumer.cs| 12 ++---
 .../SimpleSubscriptionSettings.cs  |  8 +--
 csharp/rocketmq-client-csharp/StatusChecker.cs |  6 +--
 .../rocketmq-client-csharp.csproj  |  3 +-
 .../rocketmq-client-csharp.nlog| 45 
 csharp/tests/MqLogManagerTest.cs   | 45 
 csharp/tests/tests.csproj  |  1 +
 27 files changed, 227 insertions(+), 204 deletions(-)

diff --git a/csharp/README-CN.md b/csharp/README-CN.md
index 69d9f198..dacf7a2a 100644
--- a/csharp/README-CN.md
+++ b/csharp/README-CN.md
@@ -51,14 +51,26 @@ dotnet test -l "console;verbosity=detailed"
 
 ## 日志系统
 
-我们使用 [NLog](https://nlog-project.org/) 作为日志实现，与 Java 
客户端类似，我们允许使用环境变量来自定义日志相关的配置。
+我们使用 
[Microsoft.Extensions.Logging](https://learn.microsoft.com/en-us/dotnet/core/extensions/logging?tabs=command-line#non-host-console-app)
 作为日志实现。
+
+默认的 `LoggerFactory` 是 [NLog](https://nlog-project.org/)。与 Java 
客户端类似，我们允许使用环境变量来自定义日志相关的配置：
 
 * `rocketmq_log_level`：日志输出级别，默认为 INFO。
 * `rocketmq_log_root`
   ：日志输出的根目录。默认路径为 `$HOME/logs/rocketmq`，因此完整路径为 
`$HOME/logs/rocketmq/rocketmq-client.log`。
 * `rocketmq_log_file_maxIndex`：要保留的日志文件的最大数量。默认值为 10，单个日志文件的大小限制为 64 MB。暂不支持调整。
 
-除此之外，通过将 `mq_consoleAppender_enabled` 设置为 true，您可以同时将客户端日志输出到控制台进行调试。
+如果你想使用自定义的 `LoggerFactory`，可以使用 `MqLogManager.UseLoggerFactory` 方法来配置。
+
+```csharp
+var loggerFactory = LoggerFactory.Create(builder =>
+{
+builder
+.AddFilter("Org.Apache.Rocketmq", LogLevel.Warning)
+.AddConsole();
+});
+MqLogManager.UseLoggerFactory(loggerFactory);
+```
 
 ## NuGet 包发布步骤
 
diff --git a/csharp/README.md b/csharp/README.md
index 1e648085..3b804a6d 100644
--- a/csharp/README.md
+++ b/csharp/README.md
@@ -54,7 +54,9 @@ dotnet test -l "console;verbosity=detailed"
 
 ## Logging System
 
-We use [NLog](https://nlog-project.org/) as our logging implementation. 
Similar to the Java binding, we allow the use of
+We use 
[Microsoft.Extensions.Logging](https://learn.microsoft.com/en-us/dotnet/core/extensions/logging?tabs=command-line#non-host-console-app)
 as our logging implementation.
+
+The default `LoggerFactory` is [NLog](https://nlog-project.org/). Similar to 
the Java binding, we allow the use of
 environment variables to customize the related configuration:
 
 * `rocketmq_log_level`: Log output level, default is INFO.
@@ -63,8 +65,15 @@ environment variables to customize the related configuration:
 * `rocketmq_log_file_maxIndex`: The maximum number of log files to keep. The 
default is 10, and the size of a single log
   file is limited to 64 MB. Adjustment is not supported yet.
 
-Specifically, by setting `mq_consoleAppender_enabled` to true, you can output 
client logs to the console simultaneously
-if you need debugging.
+If you want to use a custom `LoggerFactory`, you can use the 
`

[GH] (rocketmq): Workflow run "Coverage" failed!

2023-10-07 Thread GitBox 


The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
f1c382d2d68d4c510302205697e58e9eac318dcd / zhouxiang 

Add enableHeartbeatChannelEventListener for ClientConfig

Report URL: https://github.com/apache/rocketmq/actions/runs/6445877465

With regards,
GitHub Actions via GitBox

[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2023-10-07 Thread GitBox 


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
b636ae3c2404663f4c36a814ef191edcd45c7714 / zhouxiang 

Add enableHeartbeatChannelEventListener for ClientConfig

Report URL: https://github.com/apache/rocketmq/actions/runs/6445351355

With regards,
GitHub Actions via GitBox

[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2023-10-07 Thread GitBox 


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
f1c382d2d68d4c510302205697e58e9eac318dcd / zhouxiang 

Add enableHeartbeatChannelEventListener for ClientConfig

Report URL: https://github.com/apache/rocketmq/actions/runs/6445877462

With regards,
GitHub Actions via GitBox

[GH] (rocketmq): Workflow run "Coverage" failed!

2023-10-07 Thread GitBox 


The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
f1c382d2d68d4c510302205697e58e9eac318dcd / zhouxiang 

Add enableHeartbeatChannelEventListener for ClientConfig

Report URL: https://github.com/apache/rocketmq/actions/runs/6445877465

With regards,
GitHub Actions via GitBox