パッケージ org.springframework.integration.kafka.dsl

クラス KafkaTemplateSpec<K,V>

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec < KafkaTemplateSpec <K, V>、org.springframework.kafka.core.KafkaTemplate<K, V>>
org.springframework.integration.kafka.dsl.KafkaTemplateSpec<K,V>
型パラメーター:
K - 鍵の型。
V - 値の型。
実装されたすべてのインターフェース:
DisposableBean、FactoryBean<org.springframework.kafka.core.KafkaTemplate<K,V>>、InitializingBean、Lifecycle、Phased、SmartLifecycle
既知の直属サブクラス
KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec
public class KafkaTemplateSpec<K,V> extends IntegrationComponentSpec<KafkaTemplateSpec<K,V>,org.springframework.kafka.core.KafkaTemplate<K,V>>
KafkaTemplate の IntegrationComponentSpec 実装。
導入:
5.4
作成者:
Artem Bilan, Gary Russell

  • メソッドの詳細

    • getTemplate

      public org.springframework.kafka.core.KafkaTemplate<K,V> getTemplate()

    • id

      public KafkaTemplateSpec<K,V> id(@Nullable StringSE id)
      クラスからコピーされた説明: IntegrationComponentSpec
      コンポーネント識別子を構成します。このコンポーネントのアプリケーションコンテキストに Bean を登録するための beanName として使用されます。
      オーバーライド:
      クラス IntegrationComponentSpec<KafkaTemplateSpec<K,V>,org.springframework.kafka.core.KafkaTemplate<K,V>> の id 
      パラメーター:
      id - ID。
      戻り値:
      スペック。

    • defaultTopic

      public KafkaTemplateSpec<K,V> defaultTopic(StringSE defaultTopic)
      /** Set the default topic for send methods where a topic is not providing.
      パラメーター:
      defaultTopic - トピック。
      戻り値:
      スペック

    • producerListener

      public KafkaTemplateSpec<K,V> producerListener(org.springframework.kafka.support.ProducerListener<K,V> producerListener)
      Kafka が送信操作を確認したときに呼び出される ProducerListener を設定します。デフォルトでは、エラーのみをログに記録する LoggingProducerListener が構成されています。
      パラメーター:
      producerListener - リスナー ; null の可能性があります。
      戻り値:
      スペック

    • messageConverter

      public KafkaTemplateSpec<K,V> messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
      使用するメッセージコンバーターを設定します。
      パラメーター:
      messageConverter - メッセージコンバーター。
      戻り値:
      スペック