spring-cloud-dataflow

0熱

1答えて

私はしばらくの間SCDFを使用していましたが、XDとSCDFの間の主な違いはXDが生まれていることを認識していますが、SCDFはSCストリームアプリケーションのプラットフォームのように見えます。少なくともローカルサーバーはそのように動作します。私の質問は、scdfローカルサーバーが配布されている可能性がありますか？私は、ローカルサーバーが流通しているという傾向は見ません。これに関するご意見はあ

0熱

1答えて

既存のストリームの集計カウンタ

私が設定したさまざまなストリーム用の集計カウンタを作成しようとしています。 SpringXDでは、 "tap：stream：MyCustomStream> aggregate-counter"のようになります。 Spring Cloud Data Flowではこれまで「：MyKafkaTopic> aggregate-counter」を行っています。これはKafkaコンシューマを作成し、ペイロード

0熱

1答えて

Spring Cloud DataflowサーバーのRedis datasource

Spring Cloud Dataflow Serviceは、ドキュメントごとに、ストリーム/タスク定義、アプリケーション登録およびジョブリポジトリの格納にRDBMSを使用していました。 RDBMSを使用する代わりに、この情報を格納するためにRedisを使用する方法があります。

0熱

1答えて

Spring Cloud Data Flowプログラマブルアプリケーションのエラーチャネル

プロセッサ/シンクで失敗したすべてのメッセージを受け取るアプリケーションのエラーチャネルを定義またはプログラムするにはどうすればよいですか？マニュアルは、次の言葉：再試行回数は、例外をmaxAttempts値を超えていると失敗したメッセージは、メッセージのペイロードになり、アプリケーションのエラーチャネルに送信された場合。デフォルトでは、このエラーチャネルのデフォルトのメッセージハンドラはメッ

1熱

1答えて

Spring Cloudデータフローを使用して負荷に基づいてスレーブプロセスを動的にプロビジョニングできますか？

私たちは現在バッチプロセスをスケーリングするためにSpringバッチ - リモートチャンクを使用しています。クラウドのデータフローを考えていますが、負荷に基づいてスレーブを動的にプロビジョニングできるかどうかを知りたいですか？ Google Cloudにデプロイされているため、クラウドのデータフローが私たちのニーズに合致するかどうかに関わらず、kubernetesのSpring Cloudデータフ

1熱

1答えて

Spring Cloud DataflowでAvroメッセージコンバータを有効にする

Spring Cloud Dataflowでストリームアプリケーションを実装しています。私はAvroベースのスキーマレジストリクライアントをシリアライズとスキーマの制御に使用したいと考えています。私の基本的な目標は、ソースアプリケーションにいくつかの外部データを供給し、それを準備済みのavroベースのスキーマに変換し、このスキーマのみを受け入れるシンクアプリに送信することです。スキーマのファイ

0熱

1答えて

Spring Cloudデータフローアグリゲータの例

スプリッタとアグリゲータの作成方法については、Stream Cloud Data Flow（Stream XDではなく）に固有のいくつかの例を指し示すことができますか？特に、メッセージの非自明な分割と結合。複雑なストリームの例はありません。分割後にメッセージを集約しているストリームを定義する方法、生成されたメッセージのルーターと別の処理についてはどうしたら後で集計するのですか？ PS：長い質問の

0熱

1答えて

Spring Cloud Dataflowはバッファされたメッセージを出力チャネルに送信します

拒否されたメッセージをバッファするフィルタがあります。私は、述語が満たされたら、バッファリングされたメッセージを出力チャンネルに送信したいと思います。 public class MyFilter implements MessageSelector { private Buffer buff; ... @Override public boolean