org.springframework.integration.dsl.kafka

Class KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>

java.lang.Object

org.springframework.integration.dsl.core.IntegrationComponentSpec<S,H>

org.springframework.integration.dsl.core.MessageHandlerSpec<KafkaProducerMessageHandlerSpec<K,V>,org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler<K,V>>

org.springframework.integration.dsl.kafka.KafkaProducerMessageHandlerSpec<K,V>

org.springframework.integration.dsl.kafka.KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler<K,V>>, ComponentsRegistration

Enclosing class:

KafkaProducerMessageHandlerSpec<K,V>

public static class KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>
extends KafkaProducerMessageHandlerSpec<K,V>
implements ComponentsRegistration

A KafkaTemplate-based KafkaProducerMessageHandlerSpec extension.

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.dsl.kafka.KafkaProducerMessageHandlerSpec

KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>

Field Summary

Fields inherited from class org.springframework.integration.dsl.kafka.KafkaProducerMessageHandlerSpec

kafkaTemplate

Fields inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
java.util.Collection<java.lang.Object>	getComponentsToRegister()
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>	messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>	producerListener(org.springframework.kafka.support.ProducerListener<K,V> producerListener)

Methods inherited from class org.springframework.integration.dsl.kafka.KafkaProducerMessageHandlerSpec

messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, sendTimeout, sync, topic, topic, topicExpression, topicExpression

Methods inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

_this, doGet, get, getId, getObject, getObjectType, id, isSingleton

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

producerListener

public KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> producerListener(org.springframework.kafka.support.ProducerListener<K,V> producerListener)

messageConverter

public KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)

getComponentsToRegister

public java.util.Collection<java.lang.Object> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration