hill007299
6ba93446b3
[RIP-19] Pop Consuming (tools)
...
Conflicts:
tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java
tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
2022-02-08 10:38:41 +08:00
Erik1288
821b91f0a2
support batch consume-queue.
2022-02-08 10:38:41 +08:00
dongeforever
b6ff649291
feat(all):new feature for static topic
2022-02-08 10:38:41 +08:00
RongtongJin
4506f34e24
Resolve some conflicts in the merge that prevent compilation from succeeding
2021-11-01 21:01:46 +08:00
RongtongJin
f1b0318d1a
Merge remote-tracking branch 'apache/develop' into 5.0.0-alpha
...
# Conflicts:
# .travis.yml
# acl/pom.xml
# broker/pom.xml
# client/pom.xml
# common/pom.xml
# common/src/main/java/org/apache/rocketmq/common/MQVersion.java
# distribution/pom.xml
# example/pom.xml
# filter/pom.xml
# logappender/pom.xml
# logging/pom.xml
# namesrv/pom.xml
# openmessaging/pom.xml
# pom.xml
# remoting/pom.xml
# srvutil/pom.xml
# store/pom.xml
# store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java
# test/pom.xml
# tools/pom.xml
# tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
# tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
# tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java
# tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
# tools/src/test/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtTest.java
2021-11-01 12:46:26 +08:00
cserwen and dengzhiwen1
0f5a0a1e64
[ISSUE #3436 ] Make configuration for pop be configurable ( #3437 )
...
* bugfix: configuration enablePopBufferMerge not work
* make configration for pop be configurable
Co-authored-by: dengzhiwen1 <dengzhiwen1@xiaomi.com >
2021-10-29 17:38:13 +08:00
1657475997
[ISSUE#3430] fix the problem that setting parameter mqClientApiTimeout doesn't take effect ( #3431 )
...
* [maven-release-plugin] prepare release rocketmq-all-4.9.2
* [maven-release-plugin] prepare for next development iteration
* fix the problem that setting parameter mqClientApiTimeout doesn't take effect
Co-authored-by: tigerlee <tigerlee@apache.org >
Co-authored-by: haozhijie <haozhijie@kuaishou.com >
2021-10-27 14:59:12 +08:00
meateggmilk and shizhili
d2776fca95
[ISSUE #3370 ] group same Exceptions
...
Co-authored-by: shizhili <shizhili@cmss.chinamobile.com >
2021-10-26 17:08:36 +08:00
panzhi
78443c3a7c
[ISSUE 3420]rocketmq_client.log will not record the asynchronous sending failure exception，will only throw out the reason for the final time failure to the business ( #3421 )
2021-10-26 13:58:29 +08:00
alitor
6b8a2b2fce
trivial cleanups ( #3403 )
2021-10-26 13:44:23 +08:00
tigerlee
21faa68b4c
[maven-release-plugin] prepare for next development iteration
2021-10-22 13:44:14 +08:00
tigerlee
c840b20833
[maven-release-plugin] prepare release rocketmq-all-4.9.2
2021-10-22 13:43:57 +08:00
tigerlee
143ac3185b
prepare to release rocketmq 4.9.2 version
2021-10-20 00:34:12 +08:00
Git_Yang
a2c6d33a2b
[ISSUE #3415 ] Fix the problem of failure during checkstyle execution
...
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com >
2021-10-15 14:30:40 +08:00
panzhi
cd45023d61
[ISSUE #3148 ]Support metadata export ( #3149 )
2021-10-13 19:47:51 +08:00
Duan
23506fd46a
fix wrong comment ( #3400 )
2021-10-09 17:40:38 +08:00
tiger lee
7755aaa2bf
Merge pull request #3039 from Aaron-He/dev20210623
...
[ISSUE #2962 ] Implement DefaultMQAdminExt::examineTopicConfig function
2021-10-07 18:30:58 +08:00
tgen
94a527c339
[ISSUE #3288 ] Fix producer always timeouts while sending first message ( #3383 )
2021-09-28 15:39:35 +08:00
张旭 and zhangxu16
ededeb67af
[ISSUE #3371 ] Part A: Fix stack overflow exception when set message mode #3372
...
Co-authored-by: zhangxu16 <zhangxu16@xiaomi.com >
2021-09-28 13:56:55 +08:00
Git_Yang
c6a4b822ef
[ISSUE #3384 ] Add SendBack message to SCHEDULE_TOPIC_XXXX stats #3385
...
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com >
2021-09-27 14:02:21 +08:00
孙不服
daf1b9df79
[ISSUE #503 ] NOT_CONSUME_YET not righht in RocketMQ Console ( #3091 )
2021-09-27 09:07:59 +08:00
Git_Yang
b30bd87054
[ISSUE #2667 ] Repair 'file doesn't exist on this path'
...
Signed-off-by: zhangyang <Git_Yang@163.com >
2021-09-27 08:50:30 +08:00
WJL3333
d429aa24d3
[ISSUE #3375 ] Lazy init GetMessageResult only when find message
2021-09-26 18:47:27 +08:00
yuz10
6d78d7954c
fix apache rat failure because of test result files
2021-09-26 15:49:34 +08:00
Git_Yang
a83cdc5fa3
[format] Fix formatting errors ( #3380 )
...
Signed-off-by: zhangyang <Git_Yang@163.com >
2021-09-26 15:47:50 +08:00
tiger lee
4dbdbf0a25
Merge pull request #3357 from Jason918/RIP-7
...
RIP-7 Multiple Directories Storage Support
2021-09-25 22:47:22 +08:00
rongtong
538b6b7ffd
[ISSUE #1869 ] Delay message can't be consumed when delay offset in delayOffset.json is wrong ( #3358 )
...
* fix(store):delay message can't be consumed when delay offset is wrong
* fix(store):delay message can't be consumed when delay offset is wrong
* fix(common):pass the code style
* fix(store): fix bug of get cq max offset
* fix(store): polish the code
* fix(store): fix bug to pass the UT test
* chore(store): polish log format
* chore(store): polish code style
2021-09-24 17:55:02 +08:00
Silverados
fa935e832a
fix document mistake ( #3304 )
...
message.getBody() return byte[], so change to length.
2021-09-24 17:39:54 +08:00
Silverados
9013cc5f64
fix document mistake ( #3303 )
...
fix message.getBody().length() --> message.getBody().length
2021-09-24 17:39:17 +08:00
odbozhou
dd09ba1ec8
merger from develop branch and fix compile error
2021-09-24 17:06:48 +08:00
odbozhou
2bf133be29
Merge branch 'develop' into 5.0.0-preview
...
# Conflicts:
# .travis.yml
# acl/pom.xml
# broker/pom.xml
# broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
# client/pom.xml
# client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
# client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
# client/src/test/java/org/apache/rocketmq/client/impl/MQClientAPIImplTest.java
# common/pom.xml
# common/src/main/java/org/apache/rocketmq/common/MQVersion.java
# common/src/main/java/org/apache/rocketmq/common/protocol/RequestCode.java
# distribution/pom.xml
# example/pom.xml
# filter/pom.xml
# logappender/pom.xml
# logging/pom.xml
# namesrv/pom.xml
# namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
# namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
# openmessaging/pom.xml
# pom.xml
# remoting/pom.xml
# srvutil/pom.xml
# store/pom.xml
# store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
# test/pom.xml
# tools/pom.xml
# tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
2021-09-24 15:35:46 +08:00
tiger lee
1e8e728259
Merge pull request #3295 from lwclover/develop
...
[ISSUE #3308 ] production level pull api demo
2021-09-24 00:46:35 +08:00
Jiang Haiting
14d50f9808
fix a typo
2021-09-23 13:56:28 +08:00
yuz10
67f43579cf
add checkstyle to travis ci
2021-09-23 09:56:15 +08:00
tiger lee
0748aa0a5f
Merge pull request #3322 from 844392610/develop_xm
...
[ISSUE #3347 ] Improve performance of expandIP, and readable
2021-09-23 01:35:12 +08:00
Jiang Haiting
7d4e5cd659
fix compile error
2021-09-22 19:48:27 +08:00
Jiang Haiting
474c4eb147
Fix bug for multi path file loading. Opt code checking for multi-path commitlog path in storePathCommitLog.
2021-09-22 19:46:12 +08:00
Jiang Haiting
f32406d68a
change default value of org.apache.rocketmq.store.config.MessageStoreConfig#MULTI_PATH_SPLITTER to ',' and can be changed by System.getProperty("rocketmq.broker.multiPathSplitter")
2021-09-21 18:17:15 +08:00
Jiang Haiting
255a202817
add path empty check to avoid error log in org.apache.rocketmq.store.DefaultMessageStore#getRuntimeInfo
2021-09-18 16:45:28 +08:00
tiger lee
ee55441cbc
Merge pull request #3335 from zhouwentong1993/patch-1
...
[ISSUE #XXXX] Update rocketmq client maven version
2021-09-18 01:16:09 +08:00
tiger lee
a9837d9c3c
Merge pull request #2965 from zhangjidi2016/add_getConsumerConfig_command
...
[ISSUE #2964 ] Add a query consumer config command in mqadmin.
2021-09-18 01:04:42 +08:00
tiger lee
67ccb7f7be
Merge pull request #2729 from wz2cool/master
...
[ISSUE #2726 ] retrying by customizing response code
2021-09-18 00:26:32 +08:00
zhangjidi2016 and zhangjidi
0de4038f82
[ISSUE #3361 ]DefaultMQProducer's constructor can call the overloaded constructor. ( #3362 )
...
Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com >
2021-09-17 19:45:45 +08:00
Jiang Haiting
466bb98eef
fix error in org.apache.rocketmq.store.DefaultMessageStore.CleanCommitLogService#isSpaceFull
2021-09-17 11:16:28 +08:00
tiger lee
a9ae546ba0
Merge pull request #2437 from maixiaohai/DLQ_perm
...
[ISSUE #2436 ] DLQ topic default perm change
2021-09-16 14:39:14 +08:00
zhangxu16
502ca6041e
fix ci
2021-09-16 13:48:06 +08:00
Jiang Haiting
9b0e31e469
1. fix initial value of physicRatio in org.apache.rocketmq.broker.processor.SendMessageProcessor#diskUtil
...
2. use minPhysicsUsedRatio instead of max in org.apache.rocketmq.store.DefaultMessageStore#getRuntimeInfo
2021-09-16 11:04:25 +08:00
Jiang Haiting
8e19069c98
fix test error
2021-09-16 10:55:14 +08:00
Jiang Haiting
a9a7dfa722
RIP-7 Multiple Directories Storage Suppor
2021-09-15 22:36:34 +08:00
huangli
311d76f9c8
[ISSUE 3194] [PART C] Replace AtomicLong with LongAdder in StatsItem.java to improve performance ( #3351 )
2021-09-14 23:48:15 +08:00
hill007299