パッケージの使用
org.springframework.integration.kafka.dsl
org.springframework.integration.kafka.dsl を使用するパッケージ
パッケージ
説明
Apache Kafka 用の Spring Integration Java DSL コンポーネントサポートを提供します。
- クラス説明Apache Kafka トピックによってサポートされるメッセージチャネルの仕様。ポーリングされた Apache Kafka 受信チャネルアダプターの仕様。
ConcurrentMessageListenerContainer
構成のKafkaInboundGatewaySpec
拡張。ConcurrentMessageListenerContainer
構成のKafkaMessageDrivenChannelAdapterSpec
拡張。オプションをConcurrentMessageListenerContainer
に委譲するための Builder パターンスタイルのヘルパークラス。ゲートウェイとしてのKafkaProducerMessageHandler
のMessageHandlerSpec
実装。KafkaTemplate
ベースのKafkaProducerMessageHandlerSpec
拡張。KafkaTemplate
のIntegrationComponentSpec
実装。Apache Kafka トピックによってサポートされるポイントツーポイントチャネルの仕様。ポーリング可能なチャネルの仕様。KafkaTemplate
ベースのKafkaProducerMessageHandlerSpec
拡張。Apache Kafka トピックによってサポートされるパブリッシュ / サブスクライブチャネルの仕様。サブスクライブ可能なチャネルの仕様。KafkaTemplate
のIntegrationComponentSpec
実装。