クラス KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K, V>
java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec < KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec <K、V>、KafkaProducerMessageHandler <K、V>>
org.springframework.integration.dsl.MessageHandlerSpec < KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec <K、V>、KafkaProducerMessageHandler <K、V>>
org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec <K、V、KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec <K、V>>
org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>
- 型パラメーター:
K
- 鍵の型。V
- 値の型。
- 実装されたすべてのインターフェース:
DisposableBean
、FactoryBean<KafkaProducerMessageHandler<K,
、V>> InitializingBean
、Lifecycle
、Phased
、SmartLifecycle
、ComponentsRegistration
- 含まれているクラス:
KafkaProducerMessageHandlerSpec<K,
V, S extends KafkaProducerMessageHandlerSpec<K, V, S>>
public static class KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>
extends KafkaProducerMessageHandlerSpec<K,V,KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>>
implements ComponentsRegistration
KafkaTemplate
ベースの KafkaProducerMessageHandlerSpec
拡張。- 導入:
- 5.4
- 作成者:
- Artem Bilan, Biju Kunjummen, Gary Russell
ネストされたクラスのサマリー
クラス org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec から継承されたネストクラス / インターフェース
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,
V> フィールドのサマリー
クラス org.springframework.integration.dsl.IntegrationComponentSpec から継承されたフィールド
logger, PARSER, target
インターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTE
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE
メソッドのサマリー
修飾子と型メソッド説明configureKafkaTemplate
(ConsumerSE<KafkaTemplateSpec<K, V>> configurer) KafkaTemplateSpec
引数を指定してConsumer
SE コールバックを呼び出すことにより、Kafka テンプレートを構成します。クラス org.springframework.integration.kafka.dsl.KafkaProducerMessageHandlerSpec から継承されたメソッド
flush, flushExpression, flushExpression, futuresChannel, futuresChannel, headerMapper, messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, producerRecordCreator, sendFailureChannel, sendFailureChannel, sendSuccessChannel, sendSuccessChannel, sendTimeout, sync, timestamp, timestampExpression, timestampExpression, topic, topic, topicExpression, topicExpression, useTemplateConverter
クラス org.springframework.integration.dsl.IntegrationComponentSpec から継承されたメソッド
_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.beans.factory.FactoryBean から継承されたメソッド
isSingleton
メソッドの詳細
configureKafkaTemplate
public KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> configureKafkaTemplate(ConsumerSE<KafkaTemplateSpec<K, V>> configurer) KafkaTemplateSpec
引数を指定してConsumer
SE コールバックを呼び出すことにより、Kafka テンプレートを構成します。- パラメーター:
configurer
- コンフィギュレーター Java 8 Lambda。- 戻り値:
- スペック。
getComponentsToRegister
- 次で指定:
- インターフェース
ComponentsRegistration
のgetComponentsToRegister