クラスの使用
org.springframework.integration.kafka.dsl.KafkaTemplateSpec
KafkaTemplateSpec を使用するパッケージ
パッケージ
説明
Apache Kafka 用の Spring Integration Java DSL コンポーネントサポートを提供します。
org.springframework.integration.kafka.dsl 内の KafkaTemplateSpec 使用
org.springframework.integration.kafka.dsl 内の型引数 KafkaTemplateSpec を持つサブクラス修飾子と型メソッド説明KafkaTemplateSpec.defaultTopic(StringSE defaultTopic) /** Set the default topic for send methods where a topic is not providing.KafkaTemplateSpec.messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter) 使用するメッセージコンバーターを設定します。KafkaTemplateSpec.producerListener(org.springframework.kafka.support.ProducerListener<K, V> producerListener) Kafka が送信操作を確認したときに呼び出されるProducerListenerを設定します。型 KafkaTemplateSpec のパラメーターを持つ org.springframework.integration.kafka.dsl のメソッド修飾子と型メソッド説明static <K,V, R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec <K, V, R> Kafka.inboundGateway(KafkaMessageListenerContainerSpec<K, V> containerSpec, KafkaTemplateSpec<K, R> templateSpec) 提供されたコンテナーとテンプレートの仕様を使用して、初期KafkaInboundGatewaySpecを作成します。型 KafkaTemplateSpec の型引数を持つ org.springframework.integration.kafka.dsl のメソッドパラメーター修飾子と型メソッド説明KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec.configureKafkaTemplate(ConsumerSE<KafkaTemplateSpec<K, V>> configurer) KafkaTemplateSpec引数を指定してConsumerSE コールバックを呼び出すことにより、Kafka テンプレートを構成します。KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec.configureTemplate(ConsumerSE<KafkaTemplateSpec<K, R>> configurer) KafkaTemplateSpec引数を指定して、ConsumerSE コールバックを呼び出してテンプレートを構成します。