クラスの使用
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec
パッケージ
説明
Apache Kafka 用の Spring Integration Java DSL コンポーネントサポートを提供します。
org.springframework.integration.kafka.dsl 内の KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec 使用
org.springframework.integration.kafka.dsl 内の KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec 型の型引数を持つサブクラスKafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec を返す org.springframework.integration.kafka.dsl のメソッド修飾子と型メソッド説明KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec.configureKafkaTemplate
(ConsumerSE<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R>> configurer) KafkaTemplateSpec
引数を指定してConsumer
SE コールバックを呼び出すことにより、Kafka テンプレートを構成します。static <K,
V, R> KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec <K, V, R> Kafka.outboundGateway
(org.springframework.kafka.core.ProducerFactory<K, V> producerFactory, org.springframework.kafka.listener.GenericMessageListenerContainer<K, R> replyContainer) ProducerFactory を使用して初期KafkaProducerMessageHandlerSpec
を作成します。