問題タブ [spring-xd]

spring-xd 分散環境のメッセージ ストアとして redis を使用しています。

メッセージヘッダーを以下のように設定していますが、

プロセッサで受信したメッセージをチェックしている間、IDとタイムスタンプのみが表示されます

送信中のヘッダー

受信したヘッダー

ここでは、id とタイムスタンプは異なりますが、ペイロードは同じです。

この問題を解決するために私を助けてください、

前もって感謝します、-ス​​ヨーダ

マルチプロセッサでストリームを作成する方法について質問があります。例：

または

その方法を教えてください。ありがとう ！

この定義でストリームを作成しようとしました:

そして、このエラーがスローされました：

ドキュメントを調べましたが、なぜ失敗したのかわかりませんでした。

を実行しても、属性が表示され"info"ません。--properties-location

これを解決する方法はありますか？

Spring XD のシンク MQTT ソース モジュールを使用すると、ペイロードで間違った値が取得されます。ストリームを特定のトピックにサブスクライブし、Eclipse の通常のクライアントも同じトピックにサブスクライブしています。ペイロードは、バイトの配列であると想定されています。私が受け取っているのと同じメッセージについて

xxxxx...0000073F、Spring XD の場合

xxxxx...000007F9、Eclipse Paho クライアント上

実際には、この値はカウンターであると想定されており、Eclipse paho クライアントは完全に動作しますが、Spring XD は、16 進数の数字のいずれかが F に達すると奇妙な動作をするようです。同じ理由で、カウンターまで同じ数値でスタックします。シーケンスの F を取り除くのに十分なほど増加しました。

私の質問は、Spring XD で提供される MQTT クライアントで事前処理が行われている場合、ペイロードで異なる値を取得する理由を説明することです。値を送信しているのは私自身なので、2 番目が正しいと確信しています。

ありがとう。

Spring XD は、バッチジョブを起動するためのプラットフォームを提供します。それは、すべてのバッチ ジョブのユース ケースの包括的なワークフローをカバーしていますか? または、Spring XD ユースケースのコンテキスト内で使用することを意図しています。

たとえば、Spring-Batch だけを使用したいが、必ずしもデータ インジェスト/リアルタイム分析のすべての機能を使用したくない場合でも、バッチ ワークフローを実行するためだけに Spring XD DIRT を設定することでメリットがありますか? その場合、spring-batch でサポートされているすべてのバッチ ワークフローを使用できないという制限はありますか?

YAML ファイルを使用して構成プロパティを外部化しようとしています。プロパティの読み取りに成功し、Spring Boot アプリケーションを使用して個別に実行しました。

しかし、同じクラスを Spring バッチ ジョブ プロジェクトに統合し、ジョブをデプロイしようとすると、以下の例外が発生します。例外とはどういう意味ですか? 不適切なクラスのキャストを無効にするにはどうすればよいですか??

これらは私のMavenの依存関係です:

Windows プラットフォームで Spring XD を実行するためのベスト プラクティスは何ですか?

私が見たもののほとんどは、コマンドラインから実行しているだけです。これはデモには適していますが、本番環境ではうまく機能しません。Spring XDプロセスを開始および停止するためにWindowsサービスを作成できますか? または、Spring XD ランタイムを管理するために他に何が使用できますか。

実際、これは組み込みの Tomcat アプリケーションに適用できます。

アクティブ化するファイル内のプロファイルである環境変数spring.profiles.activeを設定しました。"qa"application.yml

しかし、この環境変数を設定し、xd-singlenode で Sprind XD を開始すると、次の例外がスローされます。

例外は何ですか?? どんな助けでも大歓迎です。

ありがとう