問題タブ [spring-cloud-stream]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
spring-cloud-stream - Spring クラウド ストリーム アプリ、Dispatcher にチャネル 'unknown.channel.name' のサブスクライバーがありません
spring-cloud-starter-stream-kafka をテストしています。以下、エラーになりました。
私の StreamApplication.java
LogProcessor.java
PersonProcessor.java
出力も表示できます。
受信者: hi 0 受信イベント ログ: 0 受信イベント ログ: 4 受信者: hi 4 受信イベント ログ: 9 受信者: hi 9
ありがとう。
spring - メッセージング ソース (つまり、RabbitMQ、Kafka) へのイベントに基づいてスプリング クラウド タスクを実行する
私はSpringクラウドタスクとSCDFの学習が初めてなので、これを尋ねます。
イベントに基づいて SCT を実行したい (メッセージが Rabbit MQ に投稿されたとします) ので、次の 2 つの方法で実行できると思います。
RabbitMQ からメッセージをポーリングし、データをストリームに送信するソースを作成します。次に、ストリームからデータを読み取るシンクを作成します。データが (ソース ストリームから) シンクに到達するとすぐに、タスクが起動されます。
これが可能かどうかわかりませんか？
別の方法として、タスク ランチャーを使用することもできます。ここで、タスク ランチャーはストリームで構成され、リスナーは rabbitMQ からのメッセージをポーリングします。メッセージが受信されると、トリガーがプロセスを開始し、タスクランチャーがタスクを起動します。しかし、どうすればメッセージデータを自分のタスクに入れることができるかわかりませんか? データを TaskLaunchRequest に追加する必要がありますか?
/li>
apache-kafka - ターゲット システムがダウンしているときに Spring Cloud Stream @StreamListener がリッスンするのを停止する
Kafka からメッセージを取得し、ターゲット システムを呼び出してレガシー Oracle DB を更新するアプリケーションがあります。
ターゲット システムがダウンしている場合、メッセージを Kafka バスに残し、一定期間処理しないシナリオを有効にしたいと考えています。サーキットブレーカーの Hystrix ベースのソリューションを考えていましたが、Spring Cloud Stream にイベントのリッスンを「停止」するように指示するメカニズムが見つかりません。私が考えることができる他の唯一の代替手段は、サーキットブレーカーが開いている場合に、これらのメッセージをエラー/再処理トピックに転送することですが、それはアンチパターンのように思えます。システムがイベントを処理するのを一時停止できるはずです。これが、マイクロ サービス アプリでの pub/sub の利点です。
どんな助けでも感謝します。
spring-boot - SpringCloudStream - spring-core バージョンで失敗する
spring boot を使って Spring Cloud Stream/App Starters をいじり始めました。Getting Started の指示に従ったところ、mvn build で次のエラーが発生しました。
pom.xml
プロパティファイル
あなたの助けに感謝します。
ありがとうカーシック
rabbitmq - SpringクラウドデータフローストリームでRabbitmqバインダーを使用する方法
特定の時間間隔に基づいてタスクを起動するストリームがあります。Rabbit バインダーを使用したいのですが、rabbitmq ブローカー プロパティを提供する構文がありません。誰かが私を助けてくれませんか。
spring - Spring Cloud Stream Kafka はヘッダーを 1 つのバインディングのみに追加します
Spring Cloud Stream のリファレンス マニュアルには、プロパティ「spring.cloud.stream.kafka.binder.headers」を使用して、すべてのバインディングのヘッダーを設定できると記載されています。特定のバインディングのヘッダーを設定する方法はありますか? たとえば、次のようなものです。
spring-boot - spring-data-stream プロジェクトで同じコンシューマー グループを持つすべてのコンシューマーに発行されたメッセージ
Zookeeper と 3 つの kafka ブローカーをローカルで実行しました。1 つのプロデューサーと 1 つのコンシューマーを開始しました。コンシューマーがメッセージを消費していることがわかります。
次に、同じコンシューマー グループ名で 3 つのコンシューマーを開始しました (Spring Boot プロジェクトなのでポートが異なります)。しかし、私が見つけたのは、すべてのコンシューマーが現在メッセージを消費 (受信) していることです。ただし、メッセージのみがコンシューマー間で繰り返されないという点で、メッセージの負荷が分散されることを期待しています。何が問題なのかわからない。
ここに私のプロパティファイルがあります
ここでのグループは timerGroup です。
消費者コード: https://github.com/codecentric/edmp-sample-stream-sink
プロデューサーコード: https://github.com/codecentric/edmp-sample-stream-source