spring-xd

3熱

1答えて

入力チャネルからのメッセージをフィルタリングし、出力上でそれらを他のものに変換するモジュールを作成したいとします。 @Filter(inputChannel = "input", outputChannel = "output") public boolean accept(final Message<?> message) { final MyObject payload = (My

1熱

1答えて

Spring XD分散モードredis構成

分散モードでSpring XDを構成しようとしていますが、残念ながらこれを実行できませんでした。私はredisを使用してモジュール間チャネルをバックしようとしていますが、3ノードのRedis 3.0クラスタを実行しています。構成に私の変更は以下の通りです、私は何かを逃していますか私は私の春のインスタンスが分散モードで実行するために、他のすべてのことを行う必要があるんなら、私に教えてください：

0熱

1答えて

mysqlデータベースに接続中にSpring XDの問題が発生しました

私はspringxdの新機能で、ストリームの下を通過する際に問題に直面しました。 stream create foo2 --definition "jdbc --fixedDelay=1 --split=1 --driverClassName=oracle.jdbc.driver.OracleDriver --url=jdbc:mysql://localhost:3306/test --query

0熱

1答えて

春XD sqoopジョブの失敗

HortonWorksのバージョンは2.4 SpringXdバージョンです。次のスタックトレースを与えています。ここで何が問題なのか教えてください。 2016-05-16T11:29:54+0530 1.3.1.RELEASE INFO main tool.CodeGenTool - Beginning code generation 2016-05-16T11:29:54+0530 1.3.1

3熱

1答えて

Spring Cloudのデータフローはバッチ処理をサポートしています

バッチ処理の高速化とクラウドへの展開が可能な、さまざまなプログラミング/ライブラリオプション（世界のJava側）を検討しています。私たちはSpringバッチ/ XD /クラウドのデータフローに出くわしました。 http://cloud.spring.io/spring-cloud-dataflow/のドキュメントのクイックレビューから、Springクラウドのデータフローにバネバッチが提供するすべて

0熱

1答えて

SpringXDでのErrorHandling

私はSpring-xdセットアップ用にMessageBusとしてRedisを設定しました。ストリームに障害が発生すると、データはエラーキューにプッシュされます。私はそれらを読んで、宛先キューに戻そうとしています。しかし、私のシンクモジュールがデータを受信するのを見ていない。私がどこに間違っているのか理解してくれますか？コードスニペット。 public RedisTemplate<String,

-4熱

1答えて

Spring-XDの将来

Spring XDがクラウドサービスに向けて春の開発ドライブとフォーカスを失ったという噂が聞こえました。私はXDを検討しているので（Apache Beamだと思うけど、まだ成熟していませんが）、噂に頼るのではなく、XDの将来のためのいくつかの事実/リリース計画を出したいと思います。

0熱

1答えて

401不正ストリーミングスプリングXD

私は、私は自分のキーでmodules.yml twitter: consumerKey: {your-consumer-key} consumerSecret: {your-consumer-secret} accessToken: {your-access-token} accessTokenSecret: {your-access-token-secre

1熱

1答えて

単一のSpring XDストリームに複数のタップを定義することができます

Rabbit MQトランスポートを使用してSpring XD 1.3.1を配布します。 Spring XDタップがメトリックでどのように機能するかを明確にしています。プライマリストリームの各メッセージがアクティブな定義済みタップのそれぞれに送信されるように、1つのストリームを複数回タップできるかどうかを知る必要があります。シナリオは、モンゴーなどのシンクに配信する前に処理しているウサギのソース

1熱

1答えて

Spring XD：log4jをログバックで使用する

私はすべてlog4jロギングを使用する一連のXDジョブモジュールを持っています。私は最近Spring XD 1.3.1にアップグレードしました。私のモジュールはもはやログに記録されていません。私のパッケージをxd-singlenode-logback.groovy構成ファイルに追加しようとしました。これは効果がありません。 slf4jを使ってダミーモジュールを作成しました。これは正しくログします