rocketmq

1熱度

1回答

我試圖從the official guide開始安裝RocketMQ，我使用jdk 1.8.0_121和maven 3.5.0。但是，在步驟mvn -Prelease-all -DskipTests clean install -U之後，沒有生成目錄distribution，因此cd distribution/target/apache-rocketmq不會成功。然後我試圖通過輸入sh bin

0熱度

1回答

如何知道哪個隊列被分配給哪個消費者-RocketMQ？

消費者隊列分配在客戶端，經紀人對此一無所知。那麼我們如何監視哪個隊列被分配給哪個客戶端？

0熱度

1回答

org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException：invokeAsyncImpl調用太快

我得到了關鍵的問題我用火箭MQ（V4.1.0-孵化）客戶端如下： 2017-10-16 16:18:12:457[ERROR][SimpleProducer$1.onException(SimpleProducer.java:44)] - send message to mq fail: org.apache.rocketmq.remoting.exception.RemotingTooMuch

1熱度

1回答

RocketMQ訂單的消息不工作

我使用RocketMQ並希望生產和消費數據orderly.I已經follwed訂單舉例： https://rocketmq.apache.org/docs/order-example/ 但在消費者監聽，短信不來有序。任何人都可以告訴這個Order消息如何工作嗎？

1熱度

1回答

RocketMQ是否支持主從自動切換？

RocketMQ支持主從自動切換嗎？我已經在v3.5.8中嘗試過，但它不起作用。所以，我只想問一個能給出準確答案的人

0熱度

1回答

RocketMQ製作人可以發送帶有多個標籤的消息嗎？

RocketMQ消費者可以與多個標籤訂閱主題這樣 consumer.subscribe("topic", "taga||tagb"); 如何生產者發送消息既taga和tagb 我嘗試使用標籤「塔加|| TAGB」發送消息，但消費者不會收到任何消息。當我被MSG_ID查詢消息，標籤爲[taga||tagb]，沒有[「塔加」，「TAGB」] Topic: handy_test Tags:

1熱度

2回答

阿帕奇rockerMQ代理未啓動

我嘗試出演rockerMQ經紀人，但我得到了錯誤信息：沒有足夠的內存用於Java運行時環境繼續。本機內存分配（mmap）無法映射提交保留內存的8589934592字節。更多信息的錯誤報告文件保存爲： /usr/local/soft/rocketMQ/incubator-rocketmq/distribution/target/apache-rocketmq/hs_err_pid6034.lo

-1熱度

1回答

consumer.setConsumeFromWhere（ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET）沒有用

我想讀從去年偏移數據，但使用： consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET) 無影響。

-1熱度

1回答

如何在RocketMQ的主題中設置分區？

我正在使用RocketMq作爲我的應用程序的消息傳遞層，我需要將創建的主題中的分區設置爲一個。如何在RocketMQ中將分區數設置爲主題？