spring-cloud-dataflow

0熱

2答えて

デフォルトのappdeployappmasterプロパティはどのように変更できますか？私はSpring DataFlow YARNを通じてアプリケーションをデプロイしようとしています。私は自分のアプリを登録し、ストリームを作成し、 "展開"ボタンをクリックします。例外アプリのStreamAppDefinitionを展開[さstreamName =ヒスト、名前=私のアプリ、registeredAp

1熱

1答えて

KafkaでSpring Cloud Dataflowを使用してCSVファイルをストリーム

Spring Cloud DataflowとKafkaでCSVファイルをストリーミングしようとしています。アイデアは、ファイルを各行に含まれるヘッダーとともに1行ずつストリームすることです。例えば、私のcsvファイルの内容は street,city,zip,state 3526 HIGH ST,SACRAMENTO,95838,CA 51 OMAHA CT,SACRAMENTO,95823,C

0熱

1答えて

Spring Cloud DataFlow - TCPソースでカスタムTCPエンコーダ/デコーダを使用する方法

私はすでにSpring XDのためにthis questionを要求しています。私は今、Spring CDFに移行しようとしています。私はthis linkを見つけました。そこでコードを再利用しようとしましたが、私のコードを変更しました。は、私は、次のPOMを作成しました： <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http

2熱

1答えて

Spring Cloud Stream JMSを作成する方法ActiveMQ

私は最近、Springには、jms（ActiveMQの仮想宛先）を活用するSpringクラウドストリームプロバイダのアルファ版があることを発見しました。これは絶対に魅力的で、私はそれを試してみたい。私は使用することができる依存関係のスナップショットを見つけたり、正しいgithubプロジェクトを作成してビルドすることができないので、私のローカルリポジトリに依存関係があります。私はこれについて何か助け

0熱

1答えて

Spring DataFlowを使用して自律型アプリケーションをデプロイする方法は？

私のアプリケーションは、設定されたカフカからトピックを読み込み、変換された結果をHadoop HDFSに書き込むように設定されています。これを行うには、Yarnクラスターノードで起動する必要があります。これを実行するには、Spring DataFlowを使用します。しかし、このアプリケーションは別のフローからの入力を必要としないので（ソースをどこで取得するかはすでに分かっています）、何も出力しま

1熱

1答えて

スプリングバッチの代わりにSpringクラウドデータフローを使用する利点

毎日フラットファイルを読み込んでデータベーステーブルに書き込むアプリケーションを作成する必要があります。 Spring Batchを使用してこの作業を行う予定です。我々が探しているの制限や追加は、それ自体が、単一のVMで実行します 1.アプリケーションです。いつでも複数のVMに展開されることはありません。 2.今後、同じパターンに従って他のファイルがある可能性があります。このシナリオでは、Sp

0熱

1答えて

spring-cloud-dataflow-kubernetesアプリのメモリ制限

spring.cloud.deployer.kubernetes.limits.memory=300Miでデプロイメントプロパティを設定しました。しかし、ストリームが展開された後、私はdocker statsでメモリ制限を確認しましたが、それでもまだxxx/640Miを返しました。 source codeを調べたところ、コードでデバッグログが出力されることがあります。しかし、LOGGING_LEV

0熱

1答えて

SpringクラウドのデータフローDestinationReslutionExceptionがサンプルソースを実行しています

サンプルspring-cloud-dataflowソースアプリケーションの実行に問題があります。アプリケーションはコード0で終了します（それが動作しているはずです）。私はそれをデバッグし、次の例外がスローされて気づいた： DestinationResolutionException: failed to look up MessageChannel with name 'output' 私はセ

0熱

1答えて

Spring Cloud Dataflowローカルサーバーはzookeeperに接続する必要がありますか？

ドッカーコンテナにscdfを設定しようとしています。すべてのコンテナは、一つのネットワークに 2つのカフカ sがポートによって公開されていると私はカフカ sがのZooKeeperに接続していると確信して s。（ない場合は、彼らが正常に開始されません）しかし、単純なストリーム stream create --name test --definition "time | log" --depl