Questions tagged [rocketmq]
RocketMQ is a low latency, reliable, scalable, easy to use message oriented middleware born from alibaba massive messaging business.
4
votes
1answer
90 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
1answer
2k views
Apache Pulsar vs. Apache RocketMQ
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 ...
1
vote
1answer
172 views
Rocketmq Management console
Firstly, wish you all a very happy new year.
Anybody using rocketmq in their projects? Seems like there is no portal or management console kind of thing where we can directly create topics similar to ...
1
vote
1answer
177 views
Does RocketMQ support master-slave auto switch?
Does RocketMQ support master-slave auto switch?
I have try it in v3.5.8, but it does not work. So, i just want ask someone who can gave accuracy answer
1
vote
1answer
94 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 ...
1
vote
2answers
215 views
apache rockerMQ broker doesn't start
i try to star rockerMQ broker,but i got the error message:
There is insufficient memory for the Java Runtime Environment to continue.
Native memory allocation (mmap) failed to map 8589934592 ...
1
vote
1answer
747 views
RocketMQ nameserver start error — Could not find or load main class
I was trying to install RocketMQ from scratch following the official guide, I used jdk 1.8.0_121 and maven 3.5.0.
However, after the step mvn -Prelease-all -DskipTests clean install -U, there was no ...
1
vote
1answer
116 views
How to configure a message channel between 2 brokers in RocketMQ
We used ActiveMQ to configure network connector to implement a message channel between 2 brokers, now we want to used RocketMQ. But I read many articles, there seems to be no concept about 'Channel' ...
1
vote
1answer
231 views
RocketMQ: how are the queues of a topic mapped to the master brokers?
As I know, In RocketMq, a "queue" is similar as a "partition" in Kafka.
One topic has multiple queues, also has multiple brokers(master and slave).
But how are the queues are mapped to the masters?
...
1
vote
1answer
60 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 ...
1
vote
0answers
94 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
0answers
83 views
rocketmq-console taking minutes of time to showing created topics from rocketMQ client
I have installed rocketMQ-4.1 in ubuntu server ( 18GB ram and 6 Core ), and also rocketMQ-console for dashboard.
https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console
Then i ...
1
vote
1answer
118 views
Performance issue on creating new topic
Currently, we have VM configured with 18GB ram, 8 core CPU.
We are running broker and nameserver both on the same machine.
As of now, we have around 3563 topics. So, name server and broker consuming ...
1
vote
1answer
113 views
RocketMQ order messaging is not working
I am using RocketMQ and want to produce and consume data orderly.I have follwed the Order Example :
https://rocketmq.apache.org/docs/order-example/
But in consumer listener, message is not coming ...
1
vote
0answers
77 views
Apache RocketMQ in Service Fabric giving exception
I am using RocketMQ in service Fabric Application.
But it is throwing exception when i am tring to create instance of ONSFactoryProperty; ONSFactoryProperty factoryInfo = new ONSFactoryProperty()
...
1
vote
0answers
87 views
The Demo example of RocketMQ in .NET SDK throwing System.TypeInitializationException exception
I am running the Demo Example given for .NET SDK RocketMQ. https://help.aliyun.com/document_detail/29561.html?spm=5176.doc29561.3.3.nIAzgT
But it is throwing the below exception.
An unhandled ...
1
vote
0answers
274 views
Error: Could not find or load main class org.apache.rocketmq.namesrv.NamesrvStartup
I setup RocketMQ following the guide of Quick Start https://rocketmq.incubator.apache.org/docs/quick-start/ ,run
sh bin/mqnamesrv
the logs shows:
Java HotSpot(TM) Server VM warning: ignoring option ...
1
vote
2answers
819 views
Rocketmq:MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]
when i send message to broker,this exception occasionally occurs.
MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while
This means broker is too busy(...
0
votes
1answer
54 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?
0
votes
1answer
144 views
Can RocketMQ producer send message with mutiple tags?
RocketMQ consumers can subscribe topic with multiple tags like this
consumer.subscribe("topic", "taga||tagb");
How can producers send messages with both taga and tagb
I have try to send message ...
0
votes
1answer
91 views
RocketMq QuickStart runbroker.sh setting too large java heap
When I refered to rocket mq quick start , I followed the tips: downloading sources and building, ran the sh to start a broker, I got
killed tips from os. So I checked the shell script, found heap size ...
0
votes
1answer
82 views
How to know which queue is allocated to which consumer-RocketMQ?
Consumer queues are allocated in client side, broker knows nothing about this.
So how can we monitor which queue is allocated to which consumer client?
0
votes
0answers
25 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
1answer
28 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 ...
0
votes
0answers
14 views
A queue can be consumed by more than one consumer thread in RocketMQ?
I'm learning rocketmq now, A topic will create 4 queues default, If the consumer has 5 threads, I wanna if one queue can be consumed by 2 threads concurrently? If so, how can the rocketmq to avoid the ...
0
votes
0answers
60 views
why doesn't ProducerManager.getGroupChannelTable() just return groupChannelTable in rocketmq?
Below is implement of getGroupChannelTable(), what I wonder is why doesn't just return groupChannelTable:
https://github.com/apache/rocketmq/blob/master/broker/src/main/java/org/apache/rocketmq/...
0
votes
0answers
175 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
0answers
23 views
how can i make sure rocketmq message Idempotency?what does it mean do it with message key?
I had read the document,it says in order to make consume the rocketmq idempotency,suggest to deal with the message key,here is the example code:
Message message = new Message();
message.setKey("...
0
votes
0answers
25 views
Rocketmq dynamic allocation of nameserver_ip in broker conf
I am doing cluster setup of rocketmq behind the Azure load-balancer. I wanted the pass the load-balancer IP in broker, instead of providing nameserver IP directly.
So that I can remove the manual ...
0
votes
0answers
24 views
Upgrading RocketMQ version without downtime
We are running Rocketmq cluster in production.
I need to upgrade RocketMQ version from 4.2.0 to 4.3.0 without Rocketmq cluster downtime.
Is this achievable?? If so please share any links related to ...
0
votes
0answers
48 views
rocketmq CODE:206 and CODE 207 both in logs: Not found the consumer group consume stats, because return offset table is empty
Found this in the rocket-console logs
org.apache.rocketmq.client.exception.MQClientException: CODE: 206 DESC: Not found the consumer group consume stats, because return offset table is empty, ...
0
votes
0answers
66 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
0answers
56 views
rocketmq create mapped file failed, server is busy or broken
my OS is windows 7,i cloned source code of the master branch from apache rocket,and followed the quick start doc(https://rocketmq.apache.org/docs/quick-start/),every thing is just fine untill i run ...
0
votes
0answers
115 views
when consumer start,warn : “the consumer's subscription not latest”
when I started a new RocketMQ consumer,consumer should started at once and pull message from broker, but I found warn log in broker and consumer log:
consumer start failed:CODE: 25 DESC: the consumer'...
0
votes
0answers
36 views
RocketMq subscription Group auto Creating after delete
I am trying to delete RocketMq subscription Group. Below is my code in c# where i am using rocketmq-tools:
DefaultMQAdminExt rocketMqAdmin = new DefaultMQAdminExt(adminId);
rocketMqAdmin....
0
votes
0answers
126 views
rocketMQ [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while
when i send message to broker,this exception occasionally occurs.
MQBrokerException: CODE: 2 DESC: [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while
How can i fix it?
0
votes
0answers
35 views
How to handle the message in %DLQ%
I'm trying to consume the message in %DLQ%,but failed. It
08:33:30.588 [RebalanceService] ERROR RocketmqClient - AllocateMessageQueueStrategy.allocate Exception. allocateMessageQueueStrategyName=AVG
...
0
votes
1answer
23 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
0answers
50 views
Exception in RocketMQ : producer service state not OK, START_FAILED
RocketMQ Broker and NameServer is Running.Message producing and consuming also working fine.But sometimes i am getting the exception : producer service state not OK, START_FAILED.Can any one tell the ...
0
votes
1answer
48 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 &...
0
votes
0answers
80 views
Parallel message sending to RocketMQ broker throwing exception
My Rocket MQ producer is sending 500 messages parallelly to 500 topics.
But message sending time for some topics, it is throwing exception, 'No route info for this topic'
But the topic has already ...
0
votes
0answers
179 views
Message queue for file transfers
My question is pretty simple. I'm looking for a MQ solution capable of reliable EDI file transfers along with some metadata attached to it.
I've tried RocketMQ recently and I've come across hardcoded ...
0
votes
1answer
467 views
rocketmq throw exception “[TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while”
version:rocketmq-all-4.1.0-incubating
We send msg 1000 QPS,sync send, but throw exception:-
[TIMEOUT_CLEAN_QUEUE] broker busy, start flow control for a while
There is the related code:
while (...
0
votes
1answer
158 views
Remoting Connection Exception - Connect to server failed
I setup RocketMQ (4.1.0-incubating-release) on macOS Sierra (10.12.3) and started it's nameserver and broker as per this instruction. Nameserver and broker start up well. However I can't create a new ...
0
votes
1answer
67 views
my rocketMQ 2m-noslave can not consumer messages
I build a rocketmq serveice on my server,it is 2m-noslave cluster,it's can be send messages to rocketmq,but my consumer cannot receive message,somebody tell me where is wrong,thinks...this is my
...
0
votes
1answer
30 views
tag collision in rocketmq
RocketMQ supports filter by tag, where I dig into the source code of the Broker. It seems the broker do the following comparison:
subscriptionData.getCodeSet().contains(tagsCode.intValue()); in org....
0
votes
1answer
287 views
org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: invokeAsyncImpl invoke too fast
I got critical issue I using Rocket MQ(v4.1.0-incubating) client as following:
2017-10-16 16:18:12:457[ERROR][SimpleProducer$1.onException(SimpleProducer.java:44)] - send message to mq fail:
org....
0
votes
1answer
154 views
Setting up a RocketMQ cluster: slave not visible & not replicating
I'm trying to set up a RocketMQ cluster, with a single name server, 1 master and 2 slaves. But, I'm running into some problems.
The version I'm running is downloaded from github/rocketmq-all-4.1.0-...
0
votes
0answers
54 views
rocketMQ run runserver.sh bring sh: /usr/local/rocketMQ/incubator-rocketmq/bin/runserver.sh: No such file or directory
rocketMQ run runserver.sh bring sh: /usr/local/rocketMQ/incubator-rocketmq/bin/runserver.sh: No such file or directory
what's wrong?
i opend the file 'runserver.sh' and run 'set ff'
it result to ...
0
votes
0answers
155 views
Have err when mvn -Prelease-all -DskipTests clean install -U
Problem as title says
the RocketMQ version i use is incubator-rocketmq-release-4.0.0-incubating
downloading from https://github.com/apache/incubator-rocketmq/tree/release-4.0.0-incubating
it has ...