spring-xd

0熱

1答えて

特定のユースケースに対してSpring Data Flowストリームを設定する際のアドバイスを探しています。私のユースケース：私は2 RDBMSを持っていると私はそれぞれに対して実行クエリの結果を比較する必要があります。クエリはほぼ同時に実行する必要があります。比較の結果に基づいて、私が作成したカスタム電子メールシンクアプリを通じて電子メールを送信できるはずです。私は（塗料用申し訳ありません

0熱

2答えて

Gemfire CacheListenerAdapterの実装ClassNotFoundException：org.apache.geode.pdx.internal.PdxType

gemfireからCacheListenerAdapterを実装しようとすると、次のエラーが発生します。 java.lang.ClassNotFoundException: org.apache.geode.pdx.internal.PdxType 私はGemFireのからのキャッシュ値を取得するために、次のコードを使用しています。 import com.gemstone.gemfire.cach

0熱

1答えて

SpringXDからSpringクラウドデータフローへの移行

現在、SpringXDを使用して、さまざまなデータソースからシンクにデータを取り込みます。 Springxdは可用性の終了が予定されているため、Spring Cloudデータフローに移行したいと考えています。 SpringXD用のカスタムモジュールがいくつか作成されています。 SCDFで同じモジュールを使用する方法。 SCDFでこれらを使用するために必要な変更は何ですか？私たちのクラスタはケルベ

1熱

1答えて

springxdストリームでHDFS-Datasetを使用してavroデータを保存してケルベロスチケットを更新できない

私はspringxdストリーム====> source-JMSキュー - >変換 - カスタムJavaプロセッサ（XML-AVRO） - > Sink-HDFS -Dataset。ストリームは正常に動作しますが、24時間後に連続接続されているため、Kerberos認証チケットを更新できず、HDFSへの書き込みが停止します。このストリームがデプロイされているコンテナを再起動していますが、問題が発生

0熱

1答えて

spring-integration-kafka 1.3.1.RELEASE：org.apache.kafka.common.serializationを使用するための回避策はありますか？

私はこの問題で遊ぶためにSpring XDを使用しています：カフカのトピック（0.9バージョン）から受け取ったメッセージを逆シリアル化するための回避策はありますか？私はカフカのソースをasuming（私のストリームを実行すると、私は春・統合・カフカ1.3.1を維持するために、依存関係を変更しようと、この <dependency> <groupId>org.springframewo

1熱

2答えて

春XDのRedisのはRedisのを実装しようとしているコレクション型MAPで

イムシンクコレクション型= LISTのような他のすべてのコレクション型のマップ stream create tTEST_GF_SINK --definition "trigger --initialDelay=0 --fixedDelay=1 --timeUnit=MINUTES --payload= 'new Date().toString()' --outputType=application

0熱

1答えて

Spring XDジョブのデプロイメントエラー

XDシェル/ XD-コンテナーが予期せず終了し、ジョブがデプロイされた状態のままであると、このエラーが複数回発生しています。 xd containerとxd-shellを再起動すると、同じ名前のジョブを再作成することができなくなります。しかし、ジョブリストにも表示されません。この問題を回避するには、新しい名前でジョブを作成しています。この問題の解決策はありますか？私はこれがWindows上のXD

0熱

1答えて

springxd JMSシンクアクノリッジ特権

springxd JMSソースの確認応答プロパティをどのように使用/カスタマイズできるかに関するドキュメントが見つかりません。ドキュメントは言う - オプションザ・JMSソースとJMSあり、以下のオプション：了承セッション確認応答モード（文字列、デフォルト：自動）事前におかげで...

1熱

1答えて

SpringXD /春の統合：生産者と消費者

ため、ばねの統合 - カフカの異なるバージョンを使用して、私は次のように構成している：私は、カスタムを春の統合・カフカ1.3.1.RELEASE を持っていますカフカ・シンクとカスタムカフカソース私が持ちたい設定：私がしたいですSpring統合カフカ1.3.1.Rafeaseを私のカスタムカフカシンクと一緒に使用すること。カフカソースロジックを変更して、Spring-integration

0熱

1答えて

FTPソース - 取得ファイル参照ファイルは

転送されるたびに私はこのようなストリームを作成言うことができます：FTPサーバー2つのファイルの両方が転送され、シンクはこのような何かをログに記録するログされますが含まれている場合 stream create --name ftpstream --definition "ftp --username=ftpuser --password=pass123 --host=host.com --remo