クラスの使用
org.springframework.integration.kafka.dsl.KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec
パッケージ
説明
Apache Kafka 用の Spring Integration Java DSL コンポーネントサポートを提供します。
org.springframework.integration.kafka.dsl 内の KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec 使用
KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec を返す org.springframework.integration.kafka.dsl のメソッド修飾子と型メソッド説明KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec.defaultReplyTimeout(DurationSE replyTimeout) デフォルトの応答タイムアウト。KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec.taskScheduler(TaskScheduler scheduler) 型 KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec の型引数を持つ org.springframework.integration.kafka.dsl のメソッドパラメーター修飾子と型メソッド説明KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec.configureKafkaTemplate(ConsumerSE<KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K, V, R>> configurer) KafkaTemplateSpec引数を指定してConsumerSE コールバックを呼び出すことにより、Kafka テンプレートを構成します。