You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/01/11 06:03:28 UTC
[GitHub] [rocketmq-client-cpp] lirong-Lee opened a new issue #340: Load balancing message delay
lirong-Lee opened a new issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340
Two clients A and B subscribe to a topic, and a Producer continuously pushes it.
When A receives a message, kill A and observe whether the message is pushed to B. If it is pushed to B, pull up A, and kill when A receives the message Drop A and repeat this operation.
The first few messages will be pushed to B. When A does not start, some messages will accumulate. Will be pushed to B in half an hour.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] lirong-Lee commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
lirong-Lee commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757677392
@ifplusor
No error will be reported when running now, but the message cannot be received using BROADCASTING, and the message can be received using CLUSTER.
BROADCASTING should still have problems.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] lirong-Lee commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
lirong-Lee commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-751959289
The problem is: if a CPushConsumer is permanently closed, it may cause some messages to be delayed for half an hour.
The specific operation is：
1、Two clients A and B CLUSTERING subscribe to a topic, and a Producer continuously pushes it.
2、When A receives a message, kill A
3、observe whether the message is pushed to B. If it is pushed to B, pull up A
4、Repeat 2 and 3 operations
5、After repeating operations 2 and 3 several times, turn off A, B will not receive a lot of messages
6、The news is piled up on the broker, and then pushed to B after half an hour
My broker uses rocketmq-4.7.1, this operation is complete.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] ifplusor commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
ifplusor commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757097200
Can you try this with new version in re_dev branch?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] lirong-Lee commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
lirong-Lee commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757608112
Hi Ifplusor
I use re_dev branch to test it is normal and will not be delayed. Is there any design difference between this branch and master?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] ifplusor commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
ifplusor commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757097200
Can you try this with new version in re_dev branch?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] lirong-Lee commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
lirong-Lee commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757642609
@Ifplusor PushConsumer in the example of rd_dev uses BROADCASTING subscription, it will report an error and cannot receive the message,Use CLUSTERING to receive messages normally.
The error message is：
[MQClientException] msg: create offset store dir failed: /home/lirongLee/.rocketmq_offsets/::1@DEFAULT/myGroup, error: -1, in </home/lirongLee/MySoft/rocketmq/tls/rocketmq-client-cpp-re_dev/src/consumer/LocalFileOffsetStore.cpp:44>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] lirong-Lee commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
lirong-Lee commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757649495
@ifplusor I used mkdir -p /home/lirongLee/.rocketmq_offsets/::1@DEFAULT/myGroup in advance.
This will not report the error log, but will not receive the message.
I think it will not be caused by the failure of the directory creation.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] lirong-Lee closed issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
lirong-Lee closed issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] ifplusor edited a comment on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
ifplusor edited a comment on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757097200
Can you do this with new version in re_dev branch?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] ifplusor commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
ifplusor commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757647431
@lirong-Lee Please check which dir create failed in path of "/home/lirongLee/.rocketmq_offsets/::1@DEFAULT/myGroup"
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] ifplusor commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
ifplusor commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-751956388
@lirong-Lee I did not understand what you mean, you can say it more clearly?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] lirong-Lee closed issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
lirong-Lee closed issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] ifplusor commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
ifplusor commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757711557
@lirong-Lee I have fixed it, again.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] lirong-Lee commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
lirong-Lee commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757758365
@ifplusor The problem has been solved
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] ifplusor commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
ifplusor commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757665298
@lirong-Lee I have fixed this issue, you can update the source code.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] ifplusor edited a comment on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
ifplusor edited a comment on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757097200
Can you do this with new version in re_dev branch?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-client-cpp] ifplusor commented on issue #340: Load balancing message delay
Posted by GitBox <gi...@apache.org>.
ifplusor commented on issue #340:
URL: https://github.com/apache/rocketmq-client-cpp/issues/340#issuecomment-757610474
@lirong-Lee The branch of re_dev is a refactored version, it has many improvements, and the dependence of boost was removed. It will be master in the future.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org