K
- the key type.V
- the value type.public static class Kafka09ProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> extends Kafka09ProducerMessageHandlerSpec<K,V> implements ComponentsRegistration
KafkaTemplate
-based Kafka09ProducerMessageHandlerSpec
extension.Kafka09ProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V>
kafkaTemplate
id, logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
Kafka09ProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> |
defaultTopic(java.lang.String defaultTopic) |
java.util.Collection<java.lang.Object> |
getComponentsToRegister() |
Kafka09ProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> |
producerListener(org.springframework.kafka.support.ProducerListener<K,V> producerListener) |
messageKey, messageKey, messageKeyExpression, messageKeyExpression, partitionId, partitionId, partitionIdExpression, partitionIdExpression, topic, topic, topicExpression, topicExpression
_this, doGet, get, getId, getObject, getObjectType, id, isSingleton
public Kafka09ProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> defaultTopic(java.lang.String defaultTopic)
public Kafka09ProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> producerListener(org.springframework.kafka.support.ProducerListener<K,V> producerListener)
public java.util.Collection<java.lang.Object> getComponentsToRegister()
getComponentsToRegister
in interface ComponentsRegistration