パッケージ org.springframework.integration.kafka.inbound
パッケージ org.springframework.integration.kafka.inbound
Apache Kafka 用の Spring Integration 受信コンポーネントを提供します。
- クラス説明Kafka 配信障害を回復するために
CommonErrorHandlerで使用できるErrorMessagePublisherの拡張。このインターフェースの実装は、通常、受信配信を再試行するための再試行テンプレートをサポートし、これは再試行コンテキストへの共通属性の追加をサポートします。KafkaInboundGateway<K,V, R> 受信ゲートウェイ。メッセージ駆動型チャネルアダプター。コンテナー、レコード、バッチのリスナーモード。KafkaMessageSource<K,V> Apache Kafka のポーリングされたメッセージソース。Kafka の場合は AcknowledgmentCallback。KafkaAckInfo の場合は AcknowledgmentCallbackFactory。KafkaAckCallback を構築するための情報。