AbelSara opened a new pull request #1384: [ISSUE #1382]Only send back part of
messages by setting ackIndex
URL: https://github.com/apache/rocketmq/pull/1384
## What is the purpose of the change
Set `ackIndex` by yourself when `consumeMessage` return `RECONSUME_LATER`.
#1382
ShannonDing merged pull request #149: [ISSUE #148] add consume/statistic.go
unit test
URL: https://github.com/apache/rocketmq-client-go/pull/149
This is an automated message from the Apache Git Service.
To respond to the mes
ShannonDing merged pull request #138: [ISSUE #137]add transaction producer
URL: https://github.com/apache/rocketmq-client-go/pull/138
This is an automated message from the Apache Git Service.
To respond to the message, please
AbelSara closed pull request #1383: [ISSUE #1382]Only send back part of
messages by setting ackIndex
URL: https://github.com/apache/rocketmq/pull/1383
This is an automated message from the Apache Git Service.
To respond to t
wenfengwang commented on issue #149: [ISSUE #148] add consume/statistic.go unit
test
URL:
https://github.com/apache/rocketmq-client-go/pull/149#issuecomment-521120947
LGTM
This is an automated message from the Apache Git Ser
wenfengwang commented on issue #138: [ISSUE #137]add transaction producer
URL:
https://github.com/apache/rocketmq-client-go/pull/138#issuecomment-521120603
LGTM
This is an automated message from the Apache Git Service.
To res
AbelSara opened a new pull request #1383: Only send back part of messages by
setting ackIndex
URL: https://github.com/apache/rocketmq/pull/1383
## What is the purpose of the change
Set `ackIndex` by yourself when `consumeMessage` return `RECONSUME_LATER`.
Issue #1382
## Br
RongtongJin commented on issue #119: fix #117
URL: https://github.com/apache/rocketmq-spring/pull/119#issuecomment-521115800
LGTM
This is an automated message from the Apache Git Service.
To respond to the message, please log
AbelSara opened a new issue #1382: support `consumer.setAckIndex()`
URL: https://github.com/apache/rocketmq/issues/1382
1. Please describe the feature you are requesting.
I want a feature that I can control number of messages which should be sent
back.
2. Provide any additional detail
Lunaticf commented on a change in pull request #1378: Fix some code style issue
and remove redundant code
URL: https://github.com/apache/rocketmq/pull/1378#discussion_r313705415
##
File path: test/src/main/java/org/apache/rocketmq/test/util/RandomUtil.java
##
@@ -116,17 +1
Lunaticf commented on a change in pull request #1378: Fix some code style issue
and remove redundant code
URL: https://github.com/apache/rocketmq/pull/1378#discussion_r313705415
##
File path: test/src/main/java/org/apache/rocketmq/test/util/RandomUtil.java
##
@@ -116,17 +1
xiangwangcheng commented on a change in pull request #1361: fix logging module
bug
URL: https://github.com/apache/rocketmq/pull/1361#discussion_r313705377
##
File path: logging/src/main/java/org/apache/rocketmq/logging/inner/Logger.java
##
@@ -88,8 +88,8 @@ synchronized vo
xiangwangcheng commented on a change in pull request #1378: Fix some code style
issue and remove redundant code
URL: https://github.com/apache/rocketmq/pull/1378#discussion_r313701575
##
File path: test/src/main/java/org/apache/rocketmq/test/util/RandomUtil.java
##
@@ -116
AbelSara closed pull request #1380: Only send back part of messages when the
status is RECONSUME_LATER.
URL: https://github.com/apache/rocketmq/pull/1380
This is an automated message from the Apache Git Service.
To respond t
wjwei323 commented on issue #340: .NET Client执行时报错
URL:
https://github.com/apache/rocketmq-externals/issues/340#issuecomment-521088117
Nuget包也会报这个错误
This is an automated message from the Apache Git Service.
To respond to the
wenfengwang commented on issue #150: the default example cause error
URL:
https://github.com/apache/rocketmq-client-go/issues/150#issuecomment-521087726
It seems that you go client version is cgo, could you instead it with the
native? 2.0.0-alpha2 is available now, and the 2.0.0-rc1 will a
Build Update for apache/rocketmq
-
Build: #3077
Status: Errored
Duration: 1 min and 34 secs
Commit: c6096a1 (litePullConsumer)
Author: King
Message: Polish lite pull consumer (#1381)
* fix unsubscribe code
* fix commit consumed offset
* fix commit consumed o
duhenglucky merged pull request #1381: Polish lite pull consumer
URL: https://github.com/apache/rocketmq/pull/1381
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
RongtongJin opened a new pull request #1381: Polish lite pull consumer
URL: https://github.com/apache/rocketmq/pull/1381
## What is the purpose of the change
Polish lite pull consumer
## Brief changelog
XX
## Verifying this change
Follow this ch
AbelSara opened a new pull request #1380: Only send back part of messages when
the status is RECONSUME_LATER.
URL: https://github.com/apache/rocketmq/pull/1380
当消息消费失败抛出异常，并且需要返回`RECONSUME_LATER`时，在`consumer`端的`MessageListenerConcurrently`中设置`consumer.setAckIndex()`支持已消费成功的消息不再进行重复的消费的功能
ShannonDing merged pull request #175: [ISSUE#145] Wrong lock flag for pull
request in orderly consume when unlock bug
URL: https://github.com/apache/rocketmq-client-cpp/pull/175
This is an automated message from the Apache G
flybalance closed issue #120: ExtRocketMQTemplateConfiguration nameServer
property is same with global property
URL: https://github.com/apache/rocketmq-spring/issues/120
This is an automated message from the Apache Git Servi
flybalance opened a new issue #120: ExtRocketMQTemplateConfiguration nameServer
property is same with global property
URL: https://github.com/apache/rocketmq-spring/issues/120
I want to send a message to a different group at the same address, but
itdoesn't work.
org.springframework.
flybalance commented on issue #115: rocketMQTemplate.convertAndSend
headers里的tag设置无效
URL: https://github.com/apache/rocketmq-spring/issues/115#issuecomment-521073316
rocketMQTemplate.convertAndSend("topicName:tagName", "message")
shaolsh opened a new pull request #119: fix #117
URL: https://github.com/apache/rocketmq-spring/pull/119
Closes #117
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
codecov-io commented on issue #149: [ISSUE #148] add consume/statistic.go unit
test
URL:
https://github.com/apache/rocketmq-client-go/pull/149#issuecomment-521068051
#
[Codecov](https://codecov.io/gh/apache/rocketmq-client-go/pull/149?src=pr&el=h1)
Report
> Merging
[#149](https://cod
codecov-io edited a comment on issue #149: [ISSUE #148] add
consume/statistic.go unit test
URL:
https://github.com/apache/rocketmq-client-go/pull/149#issuecomment-521068051
#
[Codecov](https://codecov.io/gh/apache/rocketmq-client-go/pull/149?src=pr&el=h1)
Report
> Merging
[#149](http
Hi Apache RocketMQ Community,
The Project Management Committee (PMC) for Apache RocketMQ has invited Qipeng
Li(apache id: wlliqipeng) to become PMC Member and we are pleased to
announce that he has accepted.
wlliqipeng[1][2][3], who spent much time in expanding the community. With
his great work,
Congrats.
huzongt...@cmss.chinamobile.com
于2019年8月13日周二 下午9:01写道：
> Hello all,
>
> The Apache RocketMQ team would like to announce the release of Apache
> RocketMQ 4.5.2.
>
> This release is to improve some features for apache rocketmq,such as
> adding new mqadmin API for ACL configuration,enhan
leoliuzcl opened a new issue #150: the default example cause error
URL: https://github.com/apache/rocketmq-client-go/issues/150
docker exec -it ed9af94d9ede ./mqadmin clusterList -n namesrv:9876
```
OpenJDK 64-Bit Server VM warning: ignoring option PermSize=128m; support was
jonnxu closed pull request #174: [ISSUE#145] Wrong lock flag for pull request
in orderly consume when unlock
URL: https://github.com/apache/rocketmq-client-cpp/pull/174
This is an automated message from the Apache Git Servic
jonnxu opened a new pull request #175: [ISSUE#145] Wrong lock flag for pull
request in orderly consume when unlock bug
URL: https://github.com/apache/rocketmq-client-cpp/pull/175
## What is the purpose of the change
#145 wrong lock flag for pull request in orderly consume when unloc
Hello all,
The Apache RocketMQ team would like to announce the release of Apache RocketMQ
4.5.2.
This release is to improve some features for apache rocketmq,such as adding new
mqadmin API for ACL configuration,enhancing transactional msg by putting
messages that exceed max check times to syst
RongtongJin commented on issue #117: syncSendOrderly方法的timeout参数无效
URL: https://github.com/apache/rocketmq-spring/issues/117#issuecomment-520809685
@shaolsh Thanks for your submission. It‘s indeed a bug and welcome to submit
a PR to fix this issue.
-
codecov-io edited a comment on issue #138: [ISSUE #137]add transaction producer
URL:
https://github.com/apache/rocketmq-client-go/pull/138#issuecomment-520276386
#
[Codecov](https://codecov.io/gh/apache/rocketmq-client-go/pull/138?src=pr&el=h1)
Report
> Merging
[#138](https://codecov.
gaufung opened a new pull request #149: [ISSUE #148] add consume/statistic.go
unit test
URL: https://github.com/apache/rocketmq-client-go/pull/149
## What is the purpose of the change
Add consume/statistic.go unit test
## Brief changelog
add consume/statistic_test.go file
flybalance opened a new issue #118: consumer.subscribe is not valid
URL: https://github.com/apache/rocketmq-spring/issues/118
@Override
public void prepareStart(DefaultMQPushConsumer consumer) {
try {
// consumer.subscribe("${rocketmq.marketIndexT
gaufung opened a new issue #148: Add statisitc unit test
URL: https://github.com/apache/rocketmq-client-go/issues/148
The issue tracker is **ONLY** used for the python client (feature request of
RocketMQ need to follow [RIP
process](https://github.com/apache/rocketmq/wiki/RocketMQ-Improvem
codecov-io edited a comment on issue #138: [ISSUE #137]add transaction producer
URL:
https://github.com/apache/rocketmq-client-go/pull/138#issuecomment-520276386
#
[Codecov](https://codecov.io/gh/apache/rocketmq-client-go/pull/138?src=pr&el=h1)
Report
> Merging
[#138](https://codecov.
codecov-io edited a comment on issue #138: [ISSUE #137]add transaction producer
URL:
https://github.com/apache/rocketmq-client-go/pull/138#issuecomment-520276386
#
[Codecov](https://codecov.io/gh/apache/rocketmq-client-go/pull/138?src=pr&el=h1)
Report
> Merging
[#138](https://codecov.
xujianhai666 commented on a change in pull request #138: [ISSUE #137]add
transaction producer
URL: https://github.com/apache/rocketmq-client-go/pull/138#discussion_r313351749
##
File path: internal/model.go
##
@@ -64,10 +72,79 @@ type consumerData struct {
UnitMode
duhenglucky opened a new issue #385: [Rocketmq-flink]Add acl feature support
for rocketmq-flink
URL: https://github.com/apache/rocketmq-externals/issues/385
**FEATURE REQUEST**
1. Please describe the feature you are requesting.
Add acl feature support for rocketmq-flink
2.
duhenglucky opened a new pull request #384: Add acl feature support for
rocketmq-flink
URL: https://github.com/apache/rocketmq-externals/pull/384
## What is the purpose of the change
Add acl feature support for rocketmq-flink
## Brief changelog
XX
## Verifying th
Liberxue commented on issue #1342: [ISSUE #1271] Fixed validators methods & Add
createSubscriptionGroup and topic validators
URL: https://github.com/apache/rocketmq/pull/1342#issuecomment-520775169
@zongtanghu
> This branch has conflicts
Please rebase develop branch, I go t
shaolsh opened a new issue #117: syncSendOrderly方法的timeout参数无效
URL: https://github.com/apache/rocketmq-spring/issues/117
**BUG REPORT**
org.apache.rocketmq.spring.core.RocketMQTemplate类的syncSendOrderly方法
源文件的286行，是不是应该改为：
return syncSendOrderly(destination, message, hashKey,
duhenglucky commented on issue #1375: Transactional message bug，when msg is
compress and only parepare ，haven't commit
URL: https://github.com/apache/rocketmq/issues/1375#issuecomment-520742708
@ymhh thanks for your issue, and could you pull a request to fix this issue?
we will help you t
lazyfighter opened a new issue #383: [Rocketmq-Connect-Mongo] add mongo source
connector
URL: https://github.com/apache/rocketmq-externals/issues/383
The issue tracker is **ONLY** used for bug report and feature request.
Any question or RocketMQ proposal please use our [mailing
lis
duhenglucky merged pull request #364: [ISSUE #363] File connector configures a
separate log file
URL: https://github.com/apache/rocketmq-externals/pull/364
This is an automated message from the Apache Git Service.
To respond
lance12138 opened a new issue #1379: ACL exist a bug
URL: https://github.com/apache/rocketmq/issues/1379
plain_acl.yml 配置文件中如果accessKey命名为admin相关的，且admin参数为true，broker无法启动，且报错：
java.lang.ClassCastException: java.lang.Class cannot be cast to
org.apache.rocketmq.acl.AccessValidator
ymhh commented on issue #1375: Transactional message bug，when msg is compress
and only parepare ，haven't commit
URL: https://github.com/apache/rocketmq/issues/1375#issuecomment-520734910
补充一点：
TransactionalMessageServiceImpl类的listener.resolveHalfMsg(msgExt);触发回调的逻辑也有一样的问题。会导致Producer客户
lazyfighter opened a new pull request #382: Feature/mongo
URL: https://github.com/apache/rocketmq-externals/pull/382
## What is the purpose of the change
mongo source connector
## Brief changelog
XX
## Verifying this change
Follow this checklist
duhenglucky closed issue #341: There is kafka exception when close
rocketmq-connect-kafka
URL: https://github.com/apache/rocketmq-externals/issues/341
This is an automated message from the Apache Git Service.
To respond to t
duhenglucky closed issue #346: [RocketMQ-Connect-Runtime] sourceTask setNamesrv
error
URL: https://github.com/apache/rocketmq-externals/issues/346
This is an automated message from the Apache Git Service.
To respond to the
duhenglucky closed issue #363: [RocketMQ-Connect-Runtime] File connector
configures a separate log file
URL: https://github.com/apache/rocketmq-externals/issues/363
This is an automated message from the Apache Git Service.
T
duhenglucky closed issue #372: [rocketmq-replicator]return taskConfig missing
source-record-converter
URL: https://github.com/apache/rocketmq-externals/issues/372
This is an automated message from the Apache Git Service.
To
duhenglucky closed issue #369: Polish rocketmq-connect config
URL: https://github.com/apache/rocketmq-externals/issues/369
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
duhenglucky closed issue #278: [Rocket Replicator]Define and Implement the
RmqConnector and RmqSourceTask.
URL: https://github.com/apache/rocketmq-externals/issues/278
This is an automated message from the Apache Git Service
duhenglucky merged pull request #367: [ISSUE #369]Polish rocketmq connect pom
file and config
URL: https://github.com/apache/rocketmq-externals/pull/367
This is an automated message from the Apache Git Service.
To respond to
Lunaticf commented on issue #1376: Fix some code style issue and remove
redundant code
URL: https://github.com/apache/rocketmq/pull/1376#issuecomment-520721196
> @Lunaticf Good job, but could you change the target branch of this PR to
develop branch first? we will review this PR ASAP.
Lunaticf opened a new pull request #1378: Fix some code style issue and remove
redundant code
URL: https://github.com/apache/rocketmq/pull/1378
## What is the purpose of the change
Find some code style issue,
Remove duplicated and redundant code.
## Brief changelog
C
Build Update for apache/rocketmq
-
Build: #3073
Status: Errored
Duration: 13 secs
Commit: a4270cf (mqtt)
Author: xhpscdx
Message: add mqttProcessor unit test (#1374)
View the changeset:
https://github.com/apache/rocketmq/compare/5813a8ba0e7f...a4270cff44c8
V
duhenglucky merged pull request #1374: [RIP-11] Add mqttProcessor unit test
URL: https://github.com/apache/rocketmq/pull/1374
This is an automated message from the Apache Git Service.
To respond to the message, please log on
Lunaticf closed pull request #1376: Fix some code style issue and remove
redundant code
URL: https://github.com/apache/rocketmq/pull/1376
This is an automated message from the Apache Git Service.
To respond to the message, p
duhenglucky commented on issue #1376: Fix some code style issue and remove
redundant code
URL: https://github.com/apache/rocketmq/pull/1376#issuecomment-520715067
@Lunaticf Good job, but could you change the target branch of this PR to
develop branch first? we will review this PR ASAP.
--
64 matches
Mail list logo
