bugfix> spring-boot > 投稿

私はカフカとスプリングブートアプリケーションに取り組んでいます。 java File APIを使用してドライブにファイルを作成しています。ファイルデータはデータベースにあります。アプリケーションにリポジトリとサービス層があります。ファイルサイズが50MBを超える場合、私はkafkaプロデューサーに電話をかけ、Idのリストを値として渡します。 kafkaコンシューマーでサービスメソッドを呼び出してデータをプルできますか?

回答 1 件
  • 「ファイルサイズが50MBを超える場合、kafkaプロデューサーに電話をかけ、Idのリストを値として渡す」とはどういう意味ですか? Kafkaクラスターにデータを送信するKafkaプロデューサーと、Kafkaクラスターからレコードを取得してドライブのファイルに書き込むKafkaコンシューマーを作成するだけです。

    プロジェクトにSpring Bootを使用しているため、リポジトリクラスでクエリメソッドを使用してデータベースからデータを取得し、サービスレイヤーを通過すると、Kafkaプロデューサーがジョブを実行できます。 Kafkaコンシューマーでは、Spring Kafkaの@KafkaListenerアノテーションを使用してレコードを消費するだけです。わずかなGoogle検索で見つけることができるサンプルコードが多数あります。

あなたの答え