K - 鍵の型。V - 値の型。public class KafkaTemplateSpec<K,V> extends IntegrationComponentSpec<KafkaTemplateSpec<K,V>,org.springframework.kafka.core.KafkaTemplate<K,V>>
KafkaTemplate の IntegrationComponentSpec 実装。PARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 修飾子と型 | メソッドと説明 |
|---|---|
KafkaTemplateSpec<K, V> | defaultTopic(StringSE defaultTopic)/** Set the default topic for send methods where a topic is not providing. |
org.springframework.kafka.core.KafkaTemplate<K, V> | getTemplate() |
KafkaTemplateSpec<K, V> | id(StringSE id) コンポーネント識別子を構成します。 |
KafkaTemplateSpec<K, V> | messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter) 使用するメッセージコンバーターを設定します。 |
KafkaTemplateSpec<K, V> | producerListener(org.springframework.kafka.support.ProducerListener<K, V> producerListener)Kafka が送信操作を確認したときに呼び出される ProducerListener を設定します。 |
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic KafkaTemplateSpec<K,V> id(StringSE id)
IntegrationComponentSpecbeanName として使用されます。IntegrationComponentSpec<KafkaTemplateSpec<K, V>,org.springframework.kafka.core.KafkaTemplate<K, V>> の id id - ID。public KafkaTemplateSpec<K,V> defaultTopic(StringSE defaultTopic)
defaultTopic - トピック。public KafkaTemplateSpec<K,V> producerListener(org.springframework.kafka.support.ProducerListener<K,V> producerListener)
ProducerListener を設定します。デフォルトでは、エラーのみをログに記録する LoggingProducerListener が構成されています。producerListener - リスナー ; null の可能性があります。public KafkaTemplateSpec<K,V> messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
messageConverter - メッセージコンバーター。