spring-cloud-stream

0熱

1答えて

Spring Cloud Stream Kafkaを使用して受信したイベントデータの集計を計算します

Spring Cloud Stream Kafkaを使用し始めました。私は単純なプロデューサとコンシューマアプリケーションを作成しました。これはSpring Cloud Stream Kafkaでうまく動作します。トピックを介して受け取ったイベントデータに対して集計（SUM、AVG）を計算し、Kafkaで保持する必要があります。計算された集計は、UIでRequest-Responseレイヤー

0熱

1答えて

2つのデータベースにSpringクラウドストリームを書き込む

私は1つのソースと1つのトランスを持つ春のクラウドストリームの状況があり、同じことを2つのデータベースに書き込む必要があります。私は2つのシンクを持つオプションがあるかどうかをチェックしていましたが、その方法を見つけることができません。私の場合のベストプラクティスの提案は非常に高く評価されます！

0熱

1答えて

Kafkaからファイルを送信する

Kafkaストリームを使用して、永続性を維持するためにあるWebサービスから他のWebサービスに画像ファイルを送信しています。プロセス中にイメージをバイトの配列に変換し、Base64でエンコードされた文字列に変換し、他のファイルメタデータとともにメッセージとして送信します。画像ファイルのサイズが大きいため、Kafkaはダウンしています。ファイルメタデータとともにKafkaを介してこれらのイメージ

0熱

1答えて

FileWritingMessageHandlerのAPPEND_NO_FLUSHはどのように機能しますか？

The default flush interval is 30000。なぜそれをスケジュールする前にFileWritingMessageHandler divide this interval by 3の開始メソッドは何ですか？次のストリームを作成して、spring-cloud-dataflowプロジェクトでフラッシュをテストしようとしました： '時刻| file --mode = APPEN

0熱

1答えて

Spring Cloud Dataflowローカルサーバーは配布できますか？

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

0熱

1答えて

Spring Cloud DataflowサーバーのRedis datasource

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

0熱

2答えて

どのように春の雲ストリームカフカ消費者の自動再消費の未確認のメッセージですか？

私は手動でコンシューマアプリケーションのオフセットを認識しますが、私はコンシューマがunacknowledgeメッセージを自動取得することができますが、私はそれを成功させることはできません。 cloud: stream: kafka: binder: brokers: ****:**** za-nodes: **** replic

0熱

1答えて

Spring Cloud Stream RabbitMQ

addAnnonceInputで受信したメッセージ1を返すにはどうすればいいですか？そのメッセージをクライアントに返す必要があります。 @RequestMapping(method = RequestMethod.POST, value = "/annonces") public void addAnnonce(@RequestBody AnnonceWrapper annonceWrapper

2熱

1答えて

スプリングクラウドストリームカフカ消費パターン

- 1）単一SpringBootインスタンスがたStreamListenerで注釈（メソッドを処理するために複数のスレッドを使用しない）、各パーティションからの各メッセージ？ 2）パーティションごとに複数のスレッドを構成することは可能ですか、リスナースレッドからワーカープールに手動でハンドオフする必要がありますか？