リアクティブサポート

このフレームワークは、サポートされているほぼすべての機能に対応する Reactive 版を提供します。

提供された命令型コンポーネントの前に Reactive という単語を置くと、対応する Reactive コンポーネントが見つかる可能性があります。

  • PulsarTemplate → ReactivePulsarTemplate

  • PulsarListener → ReactivePulsarListener

  • PulsarConsumerFactory → ReactivePulsarConsumerFactory

  • 等 ..

ただし、次のものはまだサポートされていません。

  • 非共有サブスクリプションでのエラー処理

  • ストリーミングモードでの @Header 経由の Pulsar ヘッダーへのアクセス

  • 観測

序文

Apache Pulsar ベースのアプリケーションでは、Spring に Spring-Boot-First アプローチを使用することをお勧めします。これにより、作業が大幅に簡素化されます。これを行うには、spring-pulsar-reactive-spring-boot-starter モジュールを依存関係として追加します。
このリファレンスの大部分は、リーダーがスターターを使用することを想定しており、それを念頭に置いて構成に関するほとんどの指示を提供しています。ただし、指示が Spring Boot スターターの使用箇所に特有である場合には、注意を払うよう努めています。

セクションの概要