spring-cloud-dataflow

0熱

1答えて

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

0熱

1答えて

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

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

0熱

1答えて

Spring Cloud Stream用にSpring Cloud Dataflow（例えば、Apache Igniteや他のInMemoryストア）でデータストアを使用できますか？

私は、SpringDefinition - HashMapを格納するために使用されたtests spring cloud dataflowを見ました。例えば、同じHashMapの中で、ストリームやタスクをInMemoryに格納するためのDateFlowServerConfigurationの設定をオーバーライドすることは可能ですか？

0熱

1答えて

春のクラウドタスクとデータフローを持つlogstash、config serverとeurekaの使用

私たちには、logstash、config、およびeurekaサーバを持つ既存のマイクロサービス環境があります。現在、Spring Cloud Data Flow（Kubernetes）環境（主にタスク/バッチ・ジョブを実行するための初期段階）を設定しています。タスクは、そのログを実行すると： Logstash：は、理想的には、以下のシナリオをサポートするために、標準的な春のブート構成を経由して

1熱

1答えて

Spring Cloud Data Flowのデプロイ時のエラー

IBM CloudemixにSpring Cloud Data Flowをデプロイしようとしています。私は、リファレンスドキュメント http://docs.spring.io/spring-cloud-dataflow-server-cloudfoundry/docs/1.1.1.RELEASE/reference/htmlsingle/ 内のすべての指示に従ったこれは私が終わるエラーです [

0熱

1答えて

Dataflow 1.2.0 YAML設定の変更

昨日私の開発環境をSpring Cloud Dataflow 1.2.0とすべてのシンク/ソースアプリの依存関係にアップグレードしました。私は2つの主要な問題があります。 javaOptsを：ローカルに配置されたアプリは、デフォルトXmxの値を持っているので、-Xmx128mは、ピックアップされていない長くています。これは私が以前に働いていたDataflow yaml configのフォーマッ

0熱

2答えて

Spring Cloud Dataflowサーバーログの管理

私は、dockerを使用してSpring Cloud Dataflowサーバーを展開しています。私はソース、プロセッサ、およびシンクとしてスプリングブートアプリケーションのカップルをデプロイすることによって、データフローサーバー内にデータ処理パイプラインを作成しました。各サービスのログにアクセスするためには、ドッカー・ダーバー（bash）の内側から尾を引くか、ドッカー・コンテナからローカル・ディス

1熱

1答えて

SCDFストリームを再展開する際のカフカオフセットの変化量はどのくらいですか？

私はとKafka 0.10.0をストリームアプリケーションに使用します。ストリームをアンデプロイしてからもう一度デプロイすると、現在のカフカトピックのオフセットになる場合がありますが、最も古いオフセットから開始することがあります。ストリームの再デプロイ時に予測可能な動作（現在のオフセット、最新のオフセット、最も古いオフセットなど）を取得するよう設定することはできますか。ストリームごとに異なる

0熱

1答えて

Spring Cloud Dataflowでjdbcユーザー認証を実装する方法はありますか？

これは私が書いた私のコードであり、ここで私のカスタムユーザーディテールサービスを使用しましたが、このコードビーンを実行しようとするたびにexpectionが出て来ています私は知りたいのですが、オブジェクトには1つのメソッドauth.jdbcAuthentication（）があります。私は、この内部のinit（） securityStateBean.setAuthenticationEnabled

0熱

1答えて

Spring Cloud Data Flowでの既存のSpring Cloud Streamアプリケーションのデプロイ

Spring Cloud Stream（SCS）を使用して、アプリケーションが既に@EnableBinding（Source.class）のソース、@EnableBinding（Processor.class））と1 sink @EnableBinding（Sink.class）は、Apache Kafkaバインダーを使用して通信します。これらのコンポーネントの構成の一部としては、私はそのよう