クラスの使用
org.springframework.integration.kafka.inbound.KafkaMessageSource
KafkaMessageSource を使用するパッケージ
パッケージ
説明
Apache Kafka のメッセージチャネル実装に関連するクラスを提供します。
Apache Kafka 用の Spring Integration Java DSL コンポーネントサポートを提供します。
org.springframework.integration.kafka.channel 内の KafkaMessageSource 使用
型 KafkaMessageSource のパラメーターを持つ org.springframework.integration.kafka.channel のコンストラクター修飾子コンストラクター説明PollableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?, ?> template, KafkaMessageSource<?, ?> source) 提供されたパラメーターを使用してインスタンスを構築します。org.springframework.integration.kafka.dsl 内の KafkaMessageSource 使用
型 KafkaMessageSource のパラメーターを持つ org.springframework.integration.kafka.dsl のメソッド修飾子と型メソッド説明static KafkaPollableChannelSpecKafka.pollableChannel(org.springframework.kafka.core.KafkaTemplate<?, ?> template, KafkaMessageSource<?, ?> source) 提供されたパラメーターを使用して、ポーリング可能なチャネルの仕様を作成します。型 KafkaMessageSource のパラメーターを持つ org.springframework.integration.kafka.dsl のコンストラクター修飾子コンストラクター説明protectedKafkaPollableChannelSpec(org.springframework.kafka.core.KafkaTemplate<?, ?> template, KafkaMessageSource<?, ?> source)