K - the key type.V - the value type.public static class KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V> extends org.springframework.integration.dsl.IntegrationComponentSpec<KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V>,org.springframework.kafka.core.KafkaTemplate<K,V>>
IntegrationComponentSpec implementation for the KafkaTemplate.| Modifier and Type | Method and Description |
|---|---|
KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V> |
defaultTopic(java.lang.String defaultTopic)
/**
Set the default topic for send methods where a topic is not
providing.
|
KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V> |
id(java.lang.String id) |
KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V> |
messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
Set the message converter to use.
|
KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V> |
producerListener(org.springframework.kafka.support.ProducerListener<K,V> producerListener)
Set a
ProducerListener which will be invoked when Kafka acknowledges
a send operation. |
public KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V> id(java.lang.String id)
id in class org.springframework.integration.dsl.IntegrationComponentSpec<KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V>,org.springframework.kafka.core.KafkaTemplate<K,V>>public KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V> defaultTopic(java.lang.String defaultTopic)
defaultTopic - the topic.public KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V> producerListener(org.springframework.kafka.support.ProducerListener<K,V> producerListener)
ProducerListener which will be invoked when Kafka acknowledges
a send operation. By default a LoggingProducerListener is configured
which logs errors only.producerListener - the listener; may be null.public KafkaProducerMessageHandlerSpec.KafkaTemplateSpec<K,V> messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
messageConverter - the message converter.