opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 02:23:24 +08:00
Code Issues Packages Projects Releases Wiki Activity
8,275 Commits 73 Branches 40 Tags
dc62d7f2e1ce4f99364599f8e23d65fd88eb1cd4
Commit Graph
8275 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
LetLetMe dc62d7f2e1 [ISSUE #7451] Override toString for TopicConfigAndQueueMapping 2023-10-13 13:45:48 +08:00
Lei Sun 28427d4012 [ISSUE #7425] Add RoccketmqControllerConsole log to fix bug (#7458) 2023-10-13 13:42:27 +08:00
rongtong 5d492c3382 [ISSUE #7444] Fix testCalculateFileSizeInPath test can not rerun in same environment (#7445) 
* Fix testCalculateFileSizeInPath test can not rerun in same environment

* Ensure that files are always deleted
 2023-10-13 11:23:30 +08:00
fujian-zfj 7e4879a3bc [ISSUE #7441] Fix log "Init the confirmOffset" keep printing error in controller mode (#7442) 
* typo int readme[ecosystem]

* fix keep printing log problem
 2023-10-11 14:45:07 +08:00
LetLetMeandLetLetMe dc3f22ffe9 add getter for class Message ,fix json serialize bug (#7439) 
Co-authored-by: LetLetMe <allen.hyt@alibaba-inc.com>
 2023-10-10 17:39:23 +08:00
Zhouxiang Zhan 4acb43ecee [ISSUE #7330] Add goaway and reconnection mechanism (#7331) 
* Add shutdown wait for NettyRemotingServer

* Add goaway and reconnection mechanism

* Add client version check

* Add enableTransparentRetry for NettyClientConfig

* Add enableReconnectForGoAway for NettyClientConfig

* fix unit test

* fix client version check
 2023-10-10 13:54:01 +08:00
mxsm 38d3d5d95d [ISSUE #7433]Update the version in the README.md document to 5.1.4 (#7434) 2023-10-10 09:37:04 +08:00
rongtong b18e564add [ISSUE #7431] Fix flaky test of DLedgerControllerTest#testBrokerLifecycleListener (#7432) 
* Fix flaky test of DLedgerControllerTest#testBrokerLifecycleListener
 2023-10-09 21:43:01 +08:00
redlsz 0027a1486d [ISSUE #7412] Fix pop revive message error when reput checkpoint 2023-10-09 16:52:10 +08:00
lk 3808387e13 [ISSUE #7429] clean channel map when CLIENT_UNREGISTER in proxy 2023-10-09 16:07:56 +08:00
Zhouxiang Zhan b9ffe0f957 [ISSUE #7296] Add ChannelEventListener for MQClientAPIImpl (#7324) 
* Add ChannelEventListener for MQClientAPIImpl

* add heartbeat when channel connect

* remove log

* Add enableHeartbeatChannelEventListener for ClientConfig
 2023-10-08 16:33:44 +08:00
Zhouxiang Zhan 84156084a4 [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
 2023-10-08 11:13:25 +08:00
shriVATSA54 c36bb78e85 [ISSUE 7313] Enhancement Optimization Method name (#7420) 
* Enhancment/method_name/#7313/

* Enhancment/method_name/#7313/

* Enhancment/method_name/#7313/
 2023-10-07 14:52:39 +08:00
ShuangxiDingand徒钟 4f1b42a7c5 [ISSUE #7410] Handle the Exception when the Proxy requests the client 
Co-authored-by: 徒钟 <shuangxi.dsx@alibaba-inc.com>
 2023-09-28 16:52:02 +08:00
tiger lee 0a6ae4605f [ISSUE #7396] Fix wrong word in BrokerController#doResterBrokerAll (#7397) 2023-09-27 14:43:15 +08:00
石臻臻(Steven shi)and石臻臻 959a98120c [ISSUE #7400] Fix getBrokerEpochSubCommand NPE 
Co-authored-by: 石臻臻 <shirenchuang.src@cainiao.com>
 2023-09-27 01:59:58 +08:00
石臻臻(Steven shi)and石臻臻 c3b86cd1e3 [ISSUE #7398] Fix ExportConfigsCommand NPE (#7399) 
Co-authored-by: 石臻臻 <shirenchuang.src@cainiao.com>
 2023-09-26 16:07:13 +08:00
Zhouxiang Zhan 3fd43353fd [ISSUE #7393] Add timeout configuration for grpc server (#7394) 
* Add timeout configuration for grpc server

* Add proxyConfig
 2023-09-26 13:53:51 +08:00
guyinyouandguyinyou d7e5c4d1a4 [ISSUE #7389] Fix the problem that getLastMappedFile function affects performance 
Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
 2023-09-25 13:37:36 +08:00
Ji Juntao 88a9d939ce [ISSUE #7381] Fix the problem of inaccurate timer message metric (#7382) 
* correct the timerMetrics' result.

* for further extension.

* checkstyle.

* use toLong.
 2023-09-23 17:38:27 +08:00
lk 73b3fde837 [maven-release-plugin] prepare for next development iteration (#7379) 2023-09-22 10:08:59 +08:00
lk 1a681bdf9b [maven-release-plugin] prepare release rocketmq-all-5.1.4 (#7377) rocketmq-all-5.1.4 2023-09-21 19:58:29 +08:00
Jixiang Jin b8610d87bb Replace loggingMetricExporter with OtlpJsonLoggingMetricExporter. (#7373) 
* Replace loggingMetricExporter with OtlpJsonLoggingMetricExporter.

* Fix bazel workspace

* Move OtlpJsonLoggingMetricExporter to proxy and controller.

* Fix Bazel imports.
 2023-09-21 16:21:44 +08:00
lk 42fcd278ca [ISSUE #7374] Prepare to release Apache RocketMQ 5.1.4 (#7375) 2023-09-20 15:41:23 +08:00
rongtong f05a8da760 Print admin queue watermark in log (#7372) 2023-09-20 15:06:21 +08:00
lizhimins 831fcc76cd [ISSUE #7363] Fix get message from tiered storage return incorrect next pull offset (#7365) 2023-09-19 10:04:04 +08:00
guyinyouandguyinyou 4a8e0d5b85 [ISSUE #7351] Allow mqadmin to operate slave nodes 
Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
 2023-09-13 16:08:03 +08:00
lizhimins fd32dae2ab [ISSUE #6633] Not clear uninitialized files and fix metadata recover (#7342) 2023-09-12 19:58:08 +08:00
yuz10 1a8e7cb17c [ISSUE #7345] Fix wrong result of searchOffset in tiered storage 2023-09-12 19:33:41 +08:00
Jixiang Jin dddd58d2cc Set experimental_ui_max_stdouterr_bytes to 10MB in bazel (#7348) 
* Set experimental_ui_max_stdouterr_bytes to 10MB and Fix IT
 2023-09-12 19:17:36 +08:00
Ao Qiao dad6ad09d1 [ISSUE #7340] Abstract Duplicate code into a method in TopicConfigManager (#7341) 2023-09-12 08:28:45 +08:00
guyinyouandguyinyou 57f04c95d3 [ISSUE #7343] Rollback modifications to registerProcessor 
Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
 2023-09-11 18:23:25 +08:00
rongtong a9e353285c Add the configuration of topicQueueLock number to better support different scenarios (#7317) 2023-09-11 15:55:18 +08:00
Ziyi Tan 0dbd0772b9 [ISSUE #7326] Split the request to register to the nameserver (#7325) 
Signed-off-by: Ziy1-Tan <ajb459684460@gmail.com>
 2023-09-11 15:48:07 +08:00
Ziyi Tan dad6b4dadf [ISSUE #7334] registerIncrementBrokerData for single topic update (#7335) 
Signed-off-by: Ziy1-Tan <ajb459684460@gmail.com>
 2023-09-11 14:34:10 +08:00
guyinyou c100d815d7 [ISSUE #7328] Convergent thread pool creation (#7329) 
* Convergence thread pool creation to facilitate subsequent iteration management

* Convergence thread pool creation in ThreadPoolMonitor.java

* fix unit test

* Convergence ThreadPool constructor

* Convergence ScheduledThreadPool constructor

* remove unused import

* Convergence ScheduledThreadPool constructor

* remove unused import

---------
 2023-09-11 10:13:56 +08:00
Ji Juntao 6fd0073d64 [ISSUE #7319] Optimize fault-tolerant mechanism for sending messages and hot update switch (#7320) 2023-09-07 20:21:16 +08:00
rongtong 628020537f [ISSUE #7293] Fix NPE when alter sync state set 2023-09-07 16:17:47 +08:00
lizhimins e11e29419f [ISSUE #7308] Adding topic blacklist and filter in tiered storage module (#7310) 2023-09-06 20:42:24 +08:00
lizhimins 37017dbaec [ISSUE #7305] Fix metrics and transactional module not shutdown while broker offline cause coredump(#7307) 2023-09-06 15:23:15 +08:00
yuz10 d67b9d64cb [ISSUE #7302] Fix singleTopicRegister code deleted in merge 2023-09-06 14:07:23 +08:00
guyinyouandguyinyou 31d10385d1 [ISSUE #7289] Fixed asynchronous send backpressure capability 
Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
 2023-09-04 14:09:32 +08:00
cnScarb f82718ae3b [ISSUE #7208] fix: when deleting topic also delete its pop retry topic (#7209) 2023-08-31 15:50:10 +08:00
yuz10 d000ef947d [ISSUE #7283] Incorrect dledger commitlog min offset after mappedFile re delete failed (#7284) 2023-08-31 09:41:33 +08:00
lizhimins c78061bf6c [ISSUE#7280] Fix and refactor handle commit exception in tiered storage (#7281) 
* refactor handle commit exception

* refactor handle commit exception

* fix handle commit exception
 2023-08-30 22:29:51 +08:00
PiteXChenandchenyong152 bd0e9c09db [ISSUE #7111] Remove responseFuture from the responseTable when exception occurs (#7112) 
* remove responseFuture when exception
* Empty-Commit

---------
Co-authored-by: chenyong152 <chenyong152@midea.com>
 2023-08-29 19:39:27 +08:00
Ji Juntao b028277018 [ISSUE #6567] [RIP-63] Queue Selection Strategy Optimization (#6568) 
Optimize the proxy's and client's selection strategy for brokers when sending messages, and use multiple selection strategies as a pipeline to filter suitable queues.
 2023-08-29 16:13:38 +08:00
ShuangxiDing 9f34f55e1d [ISSUE #7226] Filter tlvs in ppv2 which contents not are spec-compliant ASCII characters and space (#7227) 
Filter tlvs in ppv2 which not are spec-compliant ASCII characters and space
 2023-08-29 15:48:46 +08:00
yuz10 fa54915437 [ISSUE #7261] Slave high CPU usage when enableScheduleAsyncDeliver=true (#7262) 
* [ISSUE #6390] Add break to the exception of WHEEL_TIMER_NOT_ENABLE.

* fix broker start fail if mapped file size is 0

* log

* only delete the last empty file

* change dataReadAheadEnable default to true

* fix endless loop when master change to slave.
 2023-08-29 15:22:09 +08:00
Ziyi Tan 3e100103af [ISSUE #7277] Enhance rocksDBConfigToJson to support metadata counting (#7276) 2023-08-29 13:48:51 +08:00