spring-cloud-stream

0熱

1答えて

私のシステムでは、イベントの送受信にspring-cloud-streamとRabbitMQを使用しています。私はRabbitMQを実行して、サービスAをアップし、サービスBをダウンさせました。サービスは、サービスBにイベントを送信します。その後、私はサービスBになりました。そして今、私はRabbitがイベントを引き抜くことを期待していますが、何も起こりません。それは正しい行動ですか？私はRab

0熱

1答えて

Springクラウドデータフロー商用サポート

私たちは、Spring XDからKubernetesのSpringクラウドデータフローにジョブとストリームを移行しています。 Springクラウドのデータフローには商用サポートはありますか？すべてのリンクが役立ちます。

0熱

1答えて

Springコンフルエントスキーマデシリアライズの例

spring-kafka 2.0.0.Releaseを使用していて、コンフルエントなスキーマレジストリを使用してメッセージをデシリアライズするソースを作成した人はいますか？私が解決しようとしている問題は、MongoDBのイベントを発生させるkafka接続プラットフォームにDebezium CDCコネクタがあることです。私はそれらのイベントを変換して再ストリームを傍受する必要があります。イベントを

0熱

1答えて

Spring Cloud Stream - メッセージの一括受信

カフカのトピックから一括して（一度に1つずつではなくすべての10kレコードを一括処理するために）一括してメッセージを取得したい。これをSpring Cloud Streamプロセッサで実現する方法はありますか？もしそうなら、私が参照できるスニペットや例がありますか？おかげ

0熱

1答えて

ソースでもシンクでもないアプリを書くことはできますか？

私はすべてのアプリケーションを管理するためにSpring Cloud Data Flowサーバーを使用しようとしています。また、私は春にはすべて新しいです。 SFTPからファイルを読み込んでS3に書き込むアプリケーションを作成したいと思います。ファイルは非常に大きく（それぞれ〜500MB）、メッセージのペイロードとして渡すことができます。私はSFTPから読み込んでS3に書き込むので、SFTPからロ

0熱

1答えて

Springのサンプルコードが必要です。aws S3がinBoundで、Apache kafkaがアウトバウンドである必要があります。

aws s3のインバウンドとしてのSpring Integrationと、アウトバウンドとしてのApache kafkaの例が必要です。私はAWS S3からデータを読みたいとここでそれらを解析し、Apacheのカフカ話題に

0熱

1答えて

kafkaバインダーで春のクラウドストリームを使用していくつかのメッセージを優先順位付けする方法

TLDR：同じトピックの他のものよりも早急にいくつかのメッセージを処理できるようにしたいと思います。詳細な説明：私はいくつかのタスクのために互いの間で話をするカフカ、バインダーと、スプリング・クラウド・ストリームに依存する多くのスプリングmicroservicesを使用して、かなり大規模なアプリケーションに取り組んでいます。スケジュールされたタスクが多数のイベントを生成することがあります。こ

1熱

1答えて

SpringクラウドストリームバインダーkafkaがNettyで実行されない

HTTP上で継続的な状態変更を提供するために、Kafka SteamsとSpring WebfluxをNetty上で使用してストリーミングエンジンを構築したいと考えています。私は私のGradleファイル春のブートアプリで compile('org.springframework.cloud:spring-cloud-stream-binder-kafka') 依存関係を持っている場合、私は気づ

0熱

1答えて

シリアルクラウドストリーム（kafka）をシリアル化としてprotobufを使用するように設定する方法

私は、Springクラウドストリーム（kafka）を使用してプロデューサとコンシューマのマイクロサービス間でメッセージを交換しています。ネイティブjava直列化とデータを交換します。 Springクラウドのドキュメントに従って、JSON、AVROのシリアル化をサポートしています。は、いずれかが春の雲の流れにいるProtobufのシリアライズ（メッセージコンバータ）を試され ----------

0熱

1答えて

Spring Cloud Stream Kafkaバインダー：「IN_TRANSACTION状態からIN_TRANSACTION状態への無効な移行が試みられました」

Spring Cloud Streams + Kafka Bindingを使用してApache Kafkaで「正確に1つの配信」コンセプトでPoCを実行しようとしています。私はApache Kafka "kafka_2.11-1.0.0"をインストールし、プロデューサに "transactionIdPrefix"を定義しました。これはSpring Kafkaでトランザクションを有効にするために必