spring-cloud-stream

0熱

2答えて

私は、組織のCloud Foundryデプロイメントで実行されるデータ取り込みソリューションを作成するために、多くのSpring Cloud DataFlowと関連ドキュメントを読んできました。目標は、議論のために、おそらく1日3回、データのHTTPサービスをポーリングし、そのデータをPostgreSQLデータベースに挿入/更新することです。 HTTPサービスは、1日あたり10万件のレコードを提供

0熱

2答えて

Spring Stream AggregateApplication with Tomcat

WARパッケージ化されたTomcatホスト内でSpring Stream Aggreagateアプリケーションを実行するようにServletInitializerを設定しようとしています。親アプリが...のように構成され @SpringBootApplication public class MyAggregateApplication extends SpringBootServletInit

3熱

1答えて

Spring Cloud Stream RabbitMQ

RabbitMQでSpringクラウドストリームを使用する理由を理解しようとしています。私はRabbitMQ Springチュートリアル4（https://www.rabbitmq.com/tutorials/tutorial-four-spring-amqp.html）を見てきました。これは基本的に私がやりたいことです。それは、2つのキューが接続された直接交換を作成し、ルーティングキーに応じて、

3熱

2答えて

開発目的でSpringクラウドストリームバインディングを無効にするにはどうすればよいですか？

開発用のイベントでパブリケーションとサブスクリプションを無効にする必要がありますが、これに対していくつかの設定プロパティ/その他の解決策が見つかりません。これどうやってするの？で自動設定を作成し、無効にした場合は、すべてのバインディングインターフェイスをno-opスタブを生成したものに置き換えます。しかしもっと単純な解決策が存在するかもしれませんか？

1熱

1答えて

RabbitMQを通じてcorrelationIdを維持

私はクロスサービスメッセージングにRabbitMQを使用しています。私は、Springアノテーションを使用して、Exchanges/Queues/DLXなどを設定することができました。例（簡単な）キューリスナー： @RabbitListener(queues = RabbitMessageType.QueueNames.SMS_NOTIFICATIONS) public void receive

1熱

1答えて

headerMode = rawのJSON MessageHeaders

私は、SleuthでトレースするSpring Cloud Stream（SCS）カフカ製作アプリを持っています。私は春・メッセージングを公開しようとしている「GenericMessage」（すなわちMessageHeaders +ペイロード）必要の両方によって消費される：（自動的にMessageHeadersに追加されたトレースを継続すべきである） SCSの消費者 MessageHeadersを

0熱

2答えて

スプリングクラウドストリームカフカプロデューサーメッセージ

スプリングブラスストリームカフカプロデューサーをスプリングブーツでセットアップしたいですか？プロデューサーが働いていると私はカフカブローカーからのメッセージを消費することができますが、メッセージには、次のようないくつかのヘッダ情報が含まれています。 contentType "text/plain"originalContentType "application/json;charset=UTF-

0熱

1答えて

スプリングクラウドストリームを使用してタスクを実行できません

ソース、プロセッサ、シンクとして3つのアプリケーションがあります。ソースはプロセッサにメッセージを渡すことができますが、プロセッサはシンクと例外をスローするメッセージを送信できません。試してみると、ローカルで春のクラウドストリームを使用してタスクを実行するので、私はシンクpomファイルにspring-cloud-deployer-localを持ち、メインクラスには@EnableTaskLaunch