spring-xd

0熱

1答えて

Spring XDの使用1.3.1特定のモジュールの複数のインスタンスを含む複合モジュールを作成したいとします。これは可能ですか？私はこの単純な例試み： xd:>module compose --name yell --definition "upper: transform --expression=payload.toUpperCase() | exclaim: transform --ex

1熱

1答えて

メッセージを緩まないように設定する

私は、メッセージとポストを格納しているスロットルと呼ばれるspring xdコンポーネントを持っていて、それらをスロットルしてゆっくり送ります。私は3つのコンテナでxdを実行しています。 1つのコンテナが落ちます。私はメッセージがゆるいです。下は私の構成です。ポストグレイに格納しておらず、メモリやキャッシュを失っているようです。 <?xml version="1.0" encoding="UTF-

0熱

2答えて

SpringXDは、シェルコマンド

のPython/SpringXDは私の以前の記事で書かれたエラーが生じ組み合わせではありません実行に失敗し、一人でspringxdのシェルは、私のシステム上で実行成功することはできませんストリーム定義：ここ trigger --cron='0 */1 * * * *' | shell --command='ls' | log エラーメッセージです： 2016-04-19T16:06:06-0

0熱

1答えて

Spring XDは複数のコンテナ上でモジュールを実行します

私はSpring XDの新機能で、その内部について詳しく知りたいと思います。モジュールがコンテナに配備され、管理者がコンテナを管理し、いずれかのコンテナが失敗した場合、失敗したコンテナに配備されたモジュールが実行中のコンテナの1つに再配備されることを、これは、常に1つのインスタンスとして実行されるカスタムモジュールを作成するとどういう意味ですか？

2熱

1答えて

Spring XD OAuthシンクユニットテスト「null」リソースの新しいアクセストークンを取得できません

私はSpring XD用に作成するシンクの統合テストを作成しようとしています。ここに私のModuleConfiguration.java @Configuration @EnableIntegration public class ModuleConfiguration { private OAuth2AccessToken token; @Bean publ

0熱

1答えて

ストリームが正常に展開されていても、HDFSのファイルは空白のままです。

ローカルPCにWindowsXエンタープライズバージョンでspringXD 1.3.1を使用し、Hortonworks on Microsoft Azureクラウドを構成しています。 AzureのHortonworksで、私はdir xdを作成し、springxd docに記載されているように必要な権限を与えました。さらに、私はその後 fs.default.name=hdfs://13.92.19

1熱

1答えて

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

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

0熱

1答えて

アンデプロイメントなしのリロードストリーム

私はカスタムシンクモジュールを持つストリームを持っています。ストリームがデプロイされると、モジュールはデータベースに接続してプロパティを読み取ります。ストリームをアンデプロイせずにモジュールプロパティをリフレッシュしたい、つまり、データベースに変更が加えられた場合は、ストリームをアンデプロイせずにプロパティを更新できるはずです。ご意見やご提案はありますか？ありがとうございます。

1熱

1答えて

メッセージの数がカウントに達したとき、またはメッセージがチャンネルに入っているときだけチャネルから消費する

私はカスタムシンクモジュールを持っています。メッセージ数がからカウント、またはそれらがしばらくしてからチャンネルに入っているかどうかを確認します。要するに、私は一括押しをしたい。 SimpleMessageStoreでバックアップされた集約チャネルでメッセージを消費して格納した後、メッセージの数を集計しようとしましたが、チャネル内のメッセージを確認するのにMessageGroupStoreRe

0熱

1答えて

春XDエラーがそれにシェルプロセッサを備えた複合モジュールとストリームを作成

私は、複合モジュールを作成しました： module compose common-module --definition "kafka --topic=topic1 --outputType=text/plain | shell --command='script1.sh' " 私は、このモジュールを使用して、ストリーム作成： stream create stream1 --definitio