broker

1熱

1答えて

MQTTプロトコルを初めて使用しています。ドキュメントを読んでいるうちに、公開されたトピックを削除する機能はありませんでした。私の目的は、発行者が公開されたトピックを削除できるようにすることです。 mqtt文書で何かを忘れましたか？なにか提案を？ありがとう！

0熱

1答えて

カフカクラスター - プロデューサー

カフカについていくつか質問があります。もし誰かが私に助けてくれたら、私はとても感謝しています。は、事前にありがとう:) Q1を）私はパーティションはカフカブローカー間で分割されていることを知っています。しかし、分割は何に基づいていますか？たとえば、3つのブローカと6つのパーティションがある場合、各ブローカに2つのパーティションがあることを確認する方法はありますか？この分割は現在カフカでどのように

1熱

1答えて

カフカのブローカーの接続文字列を取得するには

私はカフカを初めて利用しています。メッセージを送受信するためのコンシューマクラスとプロデューサクラスを実装しようとしました。ブローカのIPとポートのリストである両方のクラスに対して、bootstrap.serversを,で区切って設定する必要があります。例えば、 producerConfig.put("bootstrap.servers", "172.16.20.207:9946,

0熱

2答えて

Mqttブローカー、古い接続を閉じる

mqttクライアントは同じクライアントIDを持っています古い接続を閉じるにはどうすればいいですか？このように New connection from 192.168.3.57 on port 1883. 1479826181: Client paho166768969170988 already connected, closing old connection. 1479826181: C

2熱

1答えて

Fiware OrionコンテキストブローカーとiotagentULコマンドの問題

私はFiwareユーザーです。私は、orionコンテキストブローカーGE、cepheus GE、およびiotagent-ulインスタンスをクラウド上の異なるVMに配置しました。私は登録要求にコマンド属性を指定するデバイスをiotエージェントに登録し、対応するエンティティは登録プロセスでコンテキストブローカで作成されました。デバイスの属性とコマンド属性の名前とタイプがのデバイスを登録すると、デバ

0熱

1答えて

私はパブリッシュサブスクライバモデル

経由でリクエストを送信できますか私の質問は、パブとサブ通信モデルに関連しています。具体的には、このシステム経由でリクエストを送信できますか？たとえば、私が出版社である場合、お客様のシステムに関する詳細情報や特定の情報が必要であることを加入者に要求することはできますか？私はデータを公開することしかできないと知っているが、私は要求を送ることができるかどうかわからない。

0熱

1答えて

ActiveMQ宛先に接続するときの認証によるセキュリティレベルの作成

Apache Activemqバージョン5.14.4を使用して、いくつかのメッセージをキューに送信して読み込みます。私は宛先に接続してユーザー名とパスワードを要求するようにセキュリティレベルを実装したいと思います。 ActiveMQ securityための公式ドキュメントを読んで、これらを含む多くの例を見て：example1、example2は、私はこれを達成するための簡易認証プラグインを使用する

0熱

1答えて

ユーザー名とパスワードをプログラムで設定してActiveMQサーバーに接続する方法は？

いくつかのメッセージを送信するためにActiveMQサーバーを作成します。私はApache Activemqバージョン5.14.4を使用しています ActiveMQサーバーに接続しようとすると、ユーザー名とパスワードの入力を求められます。そのため、以下のように単純な認証プラグインをactivemq.xmlに追加しました。ブローカー要素に String username = "admin"; St

0熱

1答えて

ルートCA、鍵、および証明書を使用してAWSブローカに接続するC＃m2mqtt

M2MQttライブラリを使用して、ルートCA、クライアント証明書、およびキーを使用してAWS MQTTブローカに接続しようとしています。しかし私は、これはFormatExceptionエラーで失敗し MqttClient client = new MqttClient( endPoint, MqttSettings.MQTT_BROKER_DEFAULT_SSL_PORT,

2熱

2答えて

ActiveMQをプログラムではなくサービスとして開始する

私はActiveMQを使用しています。一部のメッセージ用にプロデューサとコンシューマを作成します。この方法で私は接続を作成し、私は先の作成： ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(username,password,"tcp://localhost:61616"); Connection connec