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.