問題タブ [event-processor-host]

EventProcessorHost を使用して、JAVA で eventhub からのメッセージを消費しようとしています。here1とhere2の手順に従いましたが、コードを実行するとエラーが発生します..

詳細:

1. ブログで述べたように新しいストレージ アカウントを作成し、BLOB も作成しました。

2. EventProcessor クラスと ErrorNotificationHandler クラスは、Microsoft ドキュメントに記載されているとおりです。

3. register を呼び出すコードは次のとおりです...

注: ブログでは、EventProcessorHost のコンストラクターが非推奨になりました。

オンラインでエラーを検索したところ、ストレージのタイムアウトを増やすことができましたが、EventProcessorHost でストレージの特定のタイムアウトを証明する方法がわかりません。どんな助けでも感謝します。

EventHub のIEventProcessorインターフェイスには、次のメソッドがあります。

TPL.DataFlow元のバッチが小さすぎるため、event-hub から受信したメッセージを集約して投稿したいと考えています。そうすることで、データ フロー パイプラインのどこかでイベントをチェックポイントする必要があり、それはメソッドが戻った後も明らかに発生します。

Q.1:戻りcontext後に引数を使用できますProcessEventsAsyncか? それはどれほど安全ですか？
Q.2: 私がやりたいことを行うためのより良い方法はありますか?

このサンプル ( https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-node-get-started-send ) を使用しようとしていますが、未読データのみを読み取ることができません. もう1つ、2つの異なるエラーが発生しています

1) ETIMEDOUT 40.112.242.0:5671 を接続します。

2) チェックポイントの更新中にリースが失われました

ノード js サンプルでは、​​チェックポイントを設定できません。Azure/azure-sdk-for-js も試しました。しかし、上記と同じエラーが表示されます。

.netcore サンプルも実行した場合、それらは正常に動作しているため、ノード js サンプルが正常に動作しない理由がわかりません。

この問題を読み取り専用の未読データと新しいデータに修正する方法を教えてください。

Azure サービスは初めてで、イベント ハブについて学習しようとしています。イベント ハブを複数のコンシューマーにまたがる fifo キューとして使用したいと考えています。しかし、私は賃貸管理にいくつか問題があります。eph の 2 つのインスタンスをデプロイしましたが、同じコンシューマー グループを使用したいと考えています。まず、インスタンスを 1 つだけ使用してソリューションを試してみましたが、問題ありません。イベント プロセッサ ホストを別のマシンにデプロイすると、最初の 1 つの eph が接続を失うことがわかります

2 つのイベント プロセッサ ホストが同じコンシューマ グループから読み取るのは正しいですか? それともこれが問題ですか？アプローチや改善のアイデアを教えてもらえますか?

前もって感謝します！