Questions tagged [rocketmq]
RocketMQ is a low latency, reliable, scalable, easy to use message oriented middleware born from alibaba massive messaging business.
82
questions
0
votes
0
answers
12
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 ...
0
votes
0
answers
9
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.
0
votes
1
answer
13
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 ...
0
votes
1
answer
33
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 ...
-1
votes
1
answer
71
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> ...
0
votes
0
answers
18
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, ...
0
votes
1
answer
45
views
is it possible to get the group name from registerMessageListener in RocketMQ
I am using RocketMQ as the message center, this is the consumer dependencies jar:
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>...
0
votes
3
answers
77
views
RocketMq:how can get RocketMQ topic and tags using Api
How can I get all the tags in the topic of RocketMQ
0
votes
0
answers
41
views
rocketMQTemplate.asyncSend throws ConcurrentModificationException at MessageDecoder.messageProperties2String
I am using rocketmq-spring to send message which version is 2.1.0, sometimes i got ConcurrentModificationException at org.apache.rocketmq.common.message.MessageDecoder.messageProperties2String(...
0
votes
2
answers
45
views
how to sync two rocketmq cluster which are in different networks
I got rocketmq clusters named A and B, they are in network net-A and net-B separately. How could I sync their topics and messages.
0
votes
0
answers
47
views
How to config rocketmq in spring-cloud-stream 3.2.2?
The documentation on spring.io only have kafka and rabbitMQ,
The demo on github(spring-cloud-alibaba-example) only have old version,
How to config rocketMQ in spring-cloud-stream-3.2.2 or spring-...
0
votes
2
answers
94
views
How to delete the deley messages that has not been consumed?
I want to delete the sent deley message or modify the sent deley message expiration time.
0
votes
1
answer
410
views
RocketMQLog:WARN Please initialize the logger system properly?
run the Producer , show this:
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.InternalThreadLocalMap). RocketMQLog:WARN Please initialize the logger system properly.
...
0
votes
0
answers
177
views
Rocketmq broker fails
I'm deploying rocketmq on a managed GKE Kubernetes cluster. The name server starts correctly, but the broker runs in error and I cannot recognize which kind of problem occurs.
It follows the yaml ...
0
votes
1
answer
112
views
Binary not found in Kubernetes deployment
I'm trying to deploy rocketmq on my testing cluster. I started from the scripts provided in the apache/rocketmq-docker repo on github, but they do not work. I created my own yaml deployment starting ...
0
votes
0
answers
92
views
RocketMQ port explanation in docker-compose.yml
I am using the official apache/rocketmq-docker docker-compose.yml and was wondering why there is always one port missing in the subsequent order?
In broker is port 10910 missing.
broker:
image: ...
0
votes
1
answer
37
views
What is the naming convention for produceGroupName?
If I set the produceGroupName like '192.168.1.1:9889-1234-uuid',It will cause the exception:MQClientException The producer service state not OK, START_FAILED. If I only set the produceGroupName like ...
0
votes
1
answer
86
views
Why does RocketMQ not support JMS 2.0?
I wonder why RocketMQ does not support JMS 2.0? As we all know JMS 2.0 is a common stardard for mq. If RocketMQ supported JMS 2.0 it could connect with other mq products easily.
0
votes
0
answers
57
views
How to achieve sequential IO in rocketmq and Kafka
How to achieve sequential IO in rocketmq and Kafka, because there may not be exactly 1g continuous address disk space in different operating systems.
0
votes
2
answers
119
views
Dependency 'org.apache.rocketmq:rocketmq-spring-boot-starter:2.2.0' not found
Dependency org.apache.rocketmq:rocketmq-spring-boot-starter:2.2.0 not found
As shown in the image, I need to import the dependencies of rocketmq. But the IDE error message is not found.
How can I ...
0
votes
1
answer
42
views
how to deploy message queues like rocketMq or pulsar in environments where initiating connections are not allowed?
I need to publish messages to clients who run in environment where initiating connections are not allowed, but accepting connections are ok.
with rocketmq or pulsar, the issue I run into is that they ...
0
votes
1
answer
90
views
What circumstances will messages not be consumed or delay consumed in rocketmq cluster?
I have more than five hundred topic in one cluster with six nodes, I create the topic like this :
./mqadmin updateTopic -c MyCluster -n 192.168.1.100:9876 -r 16 -w 16 -t topic1;
./mqadmin updateTopic ...
0
votes
1
answer
442
views
rg.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
I just want to know why it throws this: sendDefaultImpl call timeout.
I know it maybe caused by firewall,but I have closed it.I cannot find the reasons.
Exception in thread "main" org.apache....
0
votes
1
answer
256
views
When using RocketMQ, I sending a message by async, sometimes throw ConcurrentModificationException
I'm just sending a string, I don't know why this is happening。
client-version: 4.5.2
server-version: 4.5.2
hope somebody can help me !
enter image description here
enter image description here
private ...
0
votes
1
answer
529
views
Rocketmq No topic route info in name server for the topic
I have a DLedger cluster composed of three machines, such as SA00, SA01, SA02;
Now I create a topic ops06 and import some data;
./bin/mqadmin checkMsgSendRT -n xx.xxx.1.251:9876 -s 2 -t ops06 -a 1000
...
0
votes
1
answer
132
views
How to set rockemq message expired time?
Here I am using spring-cloud-starter-stream-rocketmq and spring-message to send message dn,
e.g.
Message m = MessageBuilder.withPayload(obj).setHeader(RocketMQHeaders.TAGS, tag).build();
...
0
votes
1
answer
24
views
broker start up,where the code show the block?
broker start up is not exit,where the code shows the block?
i find some shedule,but not find anywhere await.
in this code,i just fond some server,but execute over this,why main thread not exit?
i ...
0
votes
1
answer
284
views
RocketMQ start error, print message: java.lang.ClassNotFoundException: org.apache.rocketmq.namesrv.NamesrvStartup
operating environment:
- CentOS Linux release 7.8.2003 (Core)
- openjdk version "11.0.8" 2020-07-14 LTS
- rocketmq-all-4.7.1-bin-release
preamble:
In order to get up and running quickly, I'...
1
vote
1
answer
188
views
How to config multiple nameservers using spring-cloud-stream-rocketmq
Trying to develop a microservices project using the spring-cloud-stream-rocketmq. I have the default rocketmq server and my configuration is
spring:
cloud:
stream:
default-binder: ...
0
votes
1
answer
44
views
Why RocketMQ DefaultMQProcuderImpl calls updateFaultItem even message is sent successfully
sendResult = this.sendKernelImpl(msg, mq, communicationMode, sendCallback, topicPublishInfo, timeout - costTime);
endTimestamp = System.currentTimeMillis();
this.updateFaultItem(mq.getBrokerName(), ...
0
votes
1
answer
164
views
RocketMQ Consumer await for result callback
I am using RocketMQ and want to get Message from Queue every new request
@Service
public class GetMessageFromQueue extends BaseObject {
@Resource
private RocketMQTemplate rocketMQTemplate;
@Value("${...
0
votes
0
answers
191
views
Building a rocketmq cluster with docker-compose, managing which broker is in control
I want build a rocketmq cluster on my machine, where the mode is master-slave, with docker-compose
And I can only start one broker at the same time. That say when I start master, slave exits. The ...
1
vote
1
answer
112
views
One topic with 4 queues, only one be consumed
There are some RocketMQ topics, but only one topic with 4 queues, only one queue be consumed.
RocketMQ 4.2.0
Java 1.8
The consumer group configuration:
depthConsumerGroup.setNamesrvAddr(...
0
votes
1
answer
1k
views
Failed to stop bean 'inputBindingLifecycle' with Spring Boot 2.1.5, Spring Cloud Stream Greenwich.SR1 and RocketMQ 0.9.0
I've seen a similar question here, but it's for an older version. Not sure what the conflicting version is for me, and what I need to use.
I used Spring Initializr to create my project, following ...
3
votes
2
answers
258
views
what's difference of readQueue and writeQueue
In RocketMQ the number of readQueue and number of writeQueue could be set separately, and it seems to me only the common part could work as expected.
For example, if readQueueNum is set to 8 and ...
0
votes
1
answer
731
views
How to fix ‘No topic route info in name server for the topic’ exception in RocketmqClient
I'm using apache-rocketmq to send message,but got an exception.I tryed much solutions from csdn, but it does't work.Now i hava no idea how to do with it.
This is a Linux server, running rocketmq 4.2....
0
votes
0
answers
67
views
RocketMQ connection to Z/OS IBM MQ queues
Has anyone successfully connected the 4.x version of RocketMQ to IBM MQ queues on Z/OS using the JMS connectivity? What issues did you encounter and what were the specific use cases/patterns enabled? ...
3
votes
4
answers
6k
views
Spring Boot application can handle tons of requests
I am using Spring-boot or Spring-Cloud Framework to develop a web application.
The system will be mainly for processing HTTP Restful requests from client side, and then save them in to MySQL database....
0
votes
0
answers
183
views
install rokcketmq 4.3.2 for debian ,according to the official website,but could not "Start Name Server"
tail -f ~/logs/rocketmqlogs/namesrv.log
exec the cmd ,but error
root@debian:/usr/local/mq/rocketmq-all-4.3.2# cd distribution/target/apache-rocketmq
root@debian:/usr/local/mq/rocketmq-all-4.3.2/...
0
votes
1
answer
232
views
rocketmq-client cannot consumer message
I am using rocketmq 4.3.1 client,Now I have encountered some problems. A consumer group that has been using it for a while has some unconsumed messages. Now I am new to the message queue, the consumer ...
4
votes
1
answer
1k
views
Why Thread.sleep(0) can prevent gc in rocketmq?
Recently I read source code in RocketMQ , but I can`t understand this code. Why this code can prevent gc?
https://github.com/apache/rocketmq/blob/master/store/src/main/java/org/apache/rocketmq/store/...
2
votes
1
answer
2k
views
MongoDB insertMany or bulkwrite throws duplicate key error in Java-API
When I Try to use java api to insert many data into Mongodb4.0 (replica set) it throws duplicate key errors.
The amount of data is not too large, only about 300000 . & insert in 3-5 seconds
...
0
votes
0
answers
317
views
What's the best way to handle Netty async task to http request?
I've encountered some problem when build a IoT service.
My architecture is shown as below:
UserBrowser<------>WebServer<---->NettyServer<----->Client(IoT device, auto response)
...
0
votes
1
answer
184
views
How to set the username and password when I use cluster in rocketmq?
How to set the username and password when I use cluster?
Does rocketmq suppert username and password?
1
vote
1
answer
178
views
rocketmq-cpp fatal error LNK1112: module machine type 'x64' conflicts with target machine type 'X86'
I am generating rocketmq dll from rocketmq-cpp opensource github Project.I have used folling Prequisite
boost 1.56.0,--> have build using this jam.exe msvc architecture=x86 address-model=64 ...
10
votes
1
answer
6k
views
Apache Pulsar vs. Apache RocketMQ [closed]
Apache Pulsar (by Yahoo) seems to be the next generation of Apache Kafka.
Apache RocketMQ (by Alibaba) seems to be the next generation of Apache ActiveMQ.
Both are open source distributed messaging ...
0
votes
1
answer
34
views
MessageSelector cannot be resolved
I learn to do rocketMQ "Filter Example", but in eclipse, I don't find MessageSelector. Who can help me?
rocketMQ Filter Example Documentation.
0
votes
1
answer
358
views
How to change the port of the rocketmq
i known the rocketmq's nameserver port is 9876 (default), here i can changed the port to 9877 (example) like this
echo "listenPort=9877" > port.properties
nohup sh mqnamesrv -c port.properties &...
1
vote
0
answers
249
views
bytebuffer write cost too much time
I made a load test for rocketmq, then I found a lot of long call,the long call cost much more then 100ms.But I read the source code of the long call,the main cost is the writing of bytebuffer. The ...
1
vote
1
answer
397
views
How can I connect RocketMQ broker with RocketMQ console to get the details?
I am a newbie to Apache RocketMQ. I have found that we can use RocketMQ console to get details of RocketMQ message transaction. see here
How do I connect(sync) that console with my locally running ...