90 questions
0
votes
1
answer
116
views
What is NameServerAddressList in the OPS page?
I have setup the rocketmq Dashboard and I was exploring it.
What exactly is the NameServerAddressList?. It is somehow defaulted to 127.0.0.1:9876.
Also, The dashboard looks empty, How do I monitor ...
- 151
0
votes
1
answer
123
views
why rockeqmq pull message size always equals 32? i`m setPullBatchSize(500);
rocketmq: 4.9.6
rocketmq-java-sdk: 4.9.6
jdk: 1.8
Using DefaultLitePullConsumer, there are more than 10,000 messages in the queue that have not been consumed. In the case of setPullBatchSize(500), the ...
- 13
1
vote
1
answer
951
views
RocketMQ V5.x Caused by: java.util.concurrent.CancellationException: Task was cancelled
When I follow the Quick Start.
The server has been tested on port 8081, and gRPC has been used, and the service is up and running, but when I use Java's SDK to send/consume messages, the following ...
- 11
-1
votes
1
answer
65
views
is rocketmq transactional message 2PC or 3PC?
I tend to believe 3PC ,but offical document says 2PC .
offical document link: https://rocketmq.apache.org/docs/featureBehavior/04transactionmessage/
enter image description here
the reason why is ...
0
votes
2
answers
107
views
Rocketmq message loss
I used 2 different consumers to consume data from the same topic. I expected the 2 consumers to return the same result. But I found that there were messages which was caught by the first consumer but ...
- 1
0
votes
2
answers
694
views
rocketMQ producer can send messages, but the consumer cannot consume messages
My rocketMQ producer can send messages to the queue, but the consumer cannot consume messages in a timely manner. Sometimes it will be delayed for about 10 seconds, and most of the time it will not ...
- 1
0
votes
0
answers
56
views
how to close default https connection from rocketmq nameserver 9876
I encountered a problem!!!
step 1. RocketMq server run in the windows server.
step 2. browser open https://ip:9876 appear safety warning,
http://ip:9876 is ok
I'm just want close https, how can I do ...
- 11
-2
votes
1
answer
110
views
Orderly message send back %RETRY%CONSUMERGROUP
I have a question about the method of RocektMQ ConsumeMessageOrderlyService.sendMessageBack, The method comment：max reconsume times exceeded then send to dead letter queue。
But the message was ...
0
votes
1
answer
186
views
rocketmq send a async message ,connect to nameserver failed
when i try to send a async message by rocketMQ,exception :
org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to [192.168.2.115:9876] failed
pom:
<dependency>
...
1
vote
1
answer
114
views
Newlife.RocketMQ message loss and duplicate
I am trying to do some test with RocketMQ, and I use C# with Newlife.RocketMQ. I started RocketMQ on my pc and I see the command window open and printing messages -- so that is ok.
So I wrote a simple ...
- 1,665
0
votes
1
answer
85
views
How to judge whether a topic is orderly or unordered in RocketMQ?
How to judge whether a topic is orderly or unordered? Can I view it from the RocketMQ-Console? I did not find the relevant documentation.
- 2,240
0
votes
1
answer
27
views
why use tagCode to caculate the deliverTime in ScheduleMessageService of rocketMQ
the method executeOnTimeup of ScheduleMessageService caculate the deliverTimestamp ,if the cqUnit.isTagsCodeValid() return true the tagsCode is tag hasCode,why can use this to caculate the time
CqUnit ...
- 11
0
votes
2
answers
96
views
How to set the message load balance consumption in RocketMQ with two client?
There are two Rocket MQ clients, both of which belong to the same consumption group. How to set the message load balance consumption? It seems that one client has more consumption messages and the ...
- 2,240
-1
votes
1
answer
313
views
Why the rocketmq only consumes part of the queue
After send message to the RocketMQ 4.8, I found the consumer only consumed part of the queue. This is the RocketMQ consumer code looks like:
public void appConsumer(Long appId, List<String> ...
- 41.2k
0
votes
1
answer
108
views
did anyone that send batch messages to rocketmq but message tags changed finally?
I tried to send batch messages to topic with this method below:
public SendResult send(Collection<Message> msgs,
MessageQueue messageQueue) throws MQClientException, RemotingException, ...
- 1
