* fix: when ipv6 enabled in broker, pickupStoreTimestamp size should be 12(20-8)
* fix: when ipv6 enabled in broker, pickupStoreTimestamp size should be 20
* [ISSUE #8460] part1: add extra information to the call chain of remote message reading
* [ISSUE #8460] part2: add exponential backoff and ending condition of CK rewrite, and fix checkstyle
* [ISSUE #8460] exclude test, BrokerOuterAPITest passed locally, but failed on bazel.
* bugfix broker boot succes but get fail ip addr
bug:
broker ip addr(IPV4) get fail after broker start up;
fix:
add compare ,continue when ip is start with '0.' ;
like :
The broker[broker-a, 0.0.1.1:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876;
* add config maxFilterMessageSize , not hard code
* Pass the code check style
---------
Co-authored-by: mingzhi.zhang <mingzhi.zhang@jiduauto.com>
Co-authored-by: RongtongJin <jinrongtong16@mails.ucas.ac.cn>
* add request codes' distribution and timing messages' distribution
* remove the requestCode distribution.
* add delay message latency distribution.
* add transaction metrics
* transaction metric of topics finished, v1.
* add the transaction metrics, to be tested.
* fix the judgement of putMessageResult
* optimize.
* add config.
* fix test case.
* add unit tests for transactionMetrics.
* remove chinese character
* add rocksdb metrics.
* add more rocksdb metrics.
* fix NPE
* avoid the total time is 0.
* add license
* remove useless import.
* bugfix: CopyOnWriteArray#listIterator do not support remove action when iterating
* add testcase
---------
Co-authored-by: mipengcheng3 <mipengcheng3@jd.com>
* fix#7614 Flaky test RocksDBMessageStoreTest
Signed-off-by: lizhanhui <lizhanhui@gmail.com>
* fix: give TimerMessageStoreTest#testStateAndRecover more time for Awaitability to poll and check
Signed-off-by: lizhanhui <lizhanhui@gmail.com>
* clean up exclude test list of bazel
Signed-off-by: lizhanhui <lizhanhui@gmail.com>
---------
Signed-off-by: lizhanhui <lizhanhui@gmail.com>
* fix NullPointerException when message escape to remote
* fix NumberFormatException when message retry to escape to remote
* fix timerCheckPoint of the master is not updated, causing the timer message to be replayed after master is restarted
* Use properties copies instead of referencing the same map when converting message
* [ISSUE #7592] testCleanBuffer unit test modifies, changed non-direct to direct buffer allocation
* fix: consolidate UtilAll#cleanBuffer by checking if the given buffer is direct or not
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
---------
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
* let consumer be aware of message queue assignment change
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
* add unit test for DefaultMQPushConsumer#setMessageQueueListener
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
* fix: bazel build warnings
Signed-off-by: Zhanhui Li <lizhanhui@apache.org>
* fix: set MixCommitlogTest test size as medium
Signed-off-by: Zhanhui Li <lizhanhui@apache.org>
* allow cache bazel test results
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
* fix code style issue by removing unused imports
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
* fix#7552
Signed-off-by: Zhanhui Li <lizhanhui@apache.org>
---------
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Signed-off-by: Zhanhui Li <lizhanhui@apache.org>
* bug fix: assignOffset and increaseOffset in LMQ has concurrency issues in topicQueueLock, should be in putMessageLock
* fix MultiDispatchTest
* fix MultiDispatchTest
* fix unit test
lizhimins