rocketmq

0熱

1答えて

どの消費者にどのキューが割り当てられているかを知る方法-RocketMQ？

コンシューマキューはクライアント側で割り当てられ、ブローカはこれについて何も知らない。どのようにどのキューがどのコンシューマクライアントに割り当てられているのかを監視できますか？

1熱

1答えて

RocketMQはマスタースレーブオートスイッチをサポートしていますか？

RocketMQはマスタースレーブオートスイッチをサポートしていますか？ v3.5.8で試してみましたが、うまくいきません。だから、私はちょうど正確な答えを与えることができる人に尋ねたい

-1熱

1答えて

consumer.setConsumeFromWhere（ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET）不使用

私は最後のオフセットからデータを読みたいが、使用： consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET) 影響なし。

1熱

1答えて

RocketMQネームサーバーの起動エラー - メインクラスが見つかりません。

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-rock

1熱

1答えて

RocketMQの2つのブローカ間でメッセージチャネルを設定する方法

ActiveMQを使用して2つのブローカ間でメッセージチャネルを実装するように設定しました。これでRocketMQを使用します。しかし、私は多くの記事を読んで、WebSphere MQのような 'Channel'やRocketMQのActiveMQのような 'Network Connector'についての概念はないようです。では、RockemtMQの2つのブローカー間でメッセージチャンネルを設定す

0熱

1答えて

私のrocketMQ 2m-noslaveはコンシューマーメッセージを受信できません

私は自分のサーバーにrocketmq serveiceを構築します.2m-noslaveクラスターです。それはrocketmqにメッセージを送ることができますが、私の消費者はメッセージを受け取ることができません。 ...これは私の Consumerクラスのコードであると考えて：私は財産autoCreateTopicEnableとautoCreateSubscriptionGroup'svalueが

0熱

1答えて

消費オフセット差分が負の場合、考えられる原因は何ですか？

場合によっては、消費オフセットとブローカオフセットの差がかなり異常であることがあります。この問題を解決するコミュニティのユーザーが多数います。この問題は、考えられるすべての原因とその解決策をリストすることです。

1熱

1答えて

RocketMQ注文メッセージングは、私がRocketMQを使用して生成したいのです

作業とデータorderly.Iは注文例をfollwedている消費されていません。 https://rocketmq.apache.org/docs/order-example/ しかし、消費者のリスナーに、メッセージが整然とした来ていません。この注文メッセージがどのように機能しているかは誰にでも分かりますか？