Cc

When the broker master fails，return timeout，Client will not retry.

6

**BUG REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? - While sending, kill master - What is expected to see? -...

not in lock elapsed time(ms)={}, bodyLength

3

在服务端总有莫名其妙的超时情况发生: 2021-09-13 01:44:35 WARN SendMessageThread_14 - putMessage not in lock elapsed time(ms)=980, bodyLength=22 2021-09-13 01:44:35 WARN SendMessageThread_1 - putMessage not in lock elapsed time(ms)=981, bodyLength=6864 2021-09-13 01:44:35 WARN SendMessageThread_9 -...

Replace map with circular array

1

使用环形数组替换 map ，以提高性能。 另外在多线程写入，非公平锁下，会出现 23456789 1 的顺序写入消息，导致23456789 都会等待第1条， 我测试下 1w tps 最多同时堵塞超过 300 条消息。

appendMessage poor performance 写入MappedByteBuffer 性能并不友好

1

场景是 12k 写入 12 k 消费 16 c 32 g，ssd，rocketmq 版本 4.9.1 Scenario is 12k writes 12k consumes 16c 32g, ssd, rocketmq version 4.9.1  如图片所示，我添加了一些指标采集 As shown in the...

performance optimization about CompletableFuture

9

in dledger ,Use a lot of CompletableFutures . But there is a problem,if you use thenAccept ,thenApply . the thread that executes the function is, Thread that executes complete. 在dledger...

merge GrpcMetadtaxxxConfiguration

4

#564

add avg topic size and fix bug

2

#63 add avg topic size fix bug java.io.CharConversionException: Not an ISO 8859-1 character: fix correct unit for remainHowManyDataToFlush

rocketmq_producer_message_size has bug

1

` try { //how many bytes has sent for the topic bsd = mqAdminExt.viewBrokerStatsData(masterAddr, BrokerStatsManager.TOPIC_PUT_SIZE, topic); String brokerIP = clusterInfo.getBrokerAddrTable().get(bd.getBrokerName()).getBrokerAddrs().get(MixAll.MASTER_ID); metricsService.getCollector().addTopicPutSizeMetric( bd.getCluster(), bd.getBrokerName(), brokerIP, topic, Utils.getFixedDouble(bsd.getStatsMinute().getTps()) );` in MetricsCollectTask 434...

支持dubbo 3.0 吗

3

如题所问

In not use [jasypt-spring-boot](https://github.com/ulisesbocchio/jasypt-spring-boot) , exception is IllegalArgumentException ,and print error key. `Caused by: java.lang.IllegalArgumentException: Circular placeholder reference 'AA' in property definitions at org.springframework.util.PropertyPlaceholderHelper.parseStringValue(PropertyPlaceholderHelper.java:147)` delete DefaultPropertyResolver#38 line. set the question...