public class KafkaProducerMessageHandlerSpec extends MessageHandlerSpec<KafkaProducerMessageHandlerSpec,org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler> implements ComponentsRegistration
MessageHandlerSpec implementation for the KafkaProducerMessageHandler.id, logger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
KafkaProducerMessageHandlerSpec |
addProducer(org.springframework.integration.kafka.support.ProducerMetadata producerMetadata,
java.lang.String brokerList)
Add Kafka Producer to this
KafkaProducerMessageHandler
for the provided topic and brokerList. |
protected org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler |
doGet() |
java.util.Collection<java.lang.Object> |
getComponentsToRegister() |
<P> KafkaProducerMessageHandlerSpec |
messageKey(Function<org.springframework.messaging.Message<P>,?> messageKeyFunction)
Configure a
Function that will be invoked at run time to determine the message key under
which a message will be stored in the topic. |
KafkaProducerMessageHandlerSpec |
messageKeyExpression(java.lang.String messageKeyExpression)
Configure s SpEL expression to determine the Kafka message key to store at runtime against
request Message as a root object of evaluation context.
|
<P> KafkaProducerMessageHandlerSpec |
topic(Function<org.springframework.messaging.Message<P>,java.lang.String> topicFunction)
Configure a
Function that will be invoked at run time to determine the topic to
which a message will be sent. |
KafkaProducerMessageHandlerSpec |
topicExpression(java.lang.String topicExpression)
Configure s SpEL expression to determine the Kafka topic at runtime against
request Message as a root object of evaluation context.
|
_this, get, getId, idpublic KafkaProducerMessageHandlerSpec topicExpression(java.lang.String topicExpression)
topicExpression - the topic SpEL expression.public <P> KafkaProducerMessageHandlerSpec topic(Function<org.springframework.messaging.Message<P>,java.lang.String> topicFunction)
Function that will be invoked at run time to determine the topic to
which a message will be sent. Typically used with a Java 8 Lambda expression:
.<Foo>topic(m -> m.getPayload().getTopic())
P - the expected payload type.topicFunction - the topic function.KafkaProducerMessageHandlerSpec.FunctionExpressionpublic KafkaProducerMessageHandlerSpec messageKeyExpression(java.lang.String messageKeyExpression)
messageKeyExpression - the message key SpEL expression.public <P> KafkaProducerMessageHandlerSpec messageKey(Function<org.springframework.messaging.Message<P>,?> messageKeyFunction)
Function that will be invoked at run time to determine the message key under
which a message will be stored in the topic. Typically used with a Java 8 Lambda expression:
.<Foo>messageKey(m -> m.getPayload().getKey())
P - the expected payload type.messageKeyFunction - the message key function.KafkaProducerMessageHandlerSpec.FunctionExpressionpublic KafkaProducerMessageHandlerSpec addProducer(org.springframework.integration.kafka.support.ProducerMetadata producerMetadata, java.lang.String brokerList)
KafkaProducerMessageHandler
for the provided topic and brokerList.producerMetadata - the ProducerMetadata - options for Kafka Producer.brokerList - the Kafka brokers (metadata.broker.list)
in the format host1:port1,host2:port2.public java.util.Collection<java.lang.Object> getComponentsToRegister()
getComponentsToRegister in interface ComponentsRegistrationprotected org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler doGet()
doGet in class IntegrationComponentSpec<KafkaProducerMessageHandlerSpec,org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler>