Skip to main content
  1. About
  3. Stack Internal
The 2026 Annual Developer Survey is live— take the Survey today!
Filter by
Sorted by
Tagged with
Filter by Employee ID
Score of 0
1 answer
125 views

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 ...
  • reputation score 151
Score of 0
1 answer
140 views

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 ...
  • reputation score 13
Score of 1
1 answer
960 views

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 ...
  • reputation score 11
Score of -1
1 answer
66 views

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 ...
  • reputation score 1
Score of 0
2 answers
114 views

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 ...
  • reputation score 1
Score of 0
2 answers
713 views

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 ...
  • reputation score 1
Score of 0
0 answers
58 views

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 ...
  • reputation score 11
Score of -2
1 answer
113 views

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 ...
  • reputation score 1
Score of 0
1 answer
186 views

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> ...
  • reputation score 1
Score of 1
1 answer
121 views

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 ...
  • reputation score 1665
Score of 0
1 answer
86 views

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.
  • reputation score 2240
Score of 0
1 answer
27 views

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 ...
  • reputation score 11
Score of 0
2 answers
125 views

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 ...
  • reputation score 2240
Score of -1
1 answer
321 views

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> ...
  • reputation score 41287
Score of 0
1 answer
111 views

I tried to send batch messages to topic with this method below: public SendResult send(Collection<Message> msgs, MessageQueue messageQueue) throws MQClientException, RemotingException, ...
  • reputation score 1

15 30 50 per page
1
2 3 4 5 6

AltStyle によって変換されたページ (->オリジナル) /