Uses of Class
org.springframework.integration.kafka.dsl.KafkaTemplateSpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaTemplateSpec in org.springframework.integration.kafka.dsl
Modifier and TypeClassDescriptionstatic class
AnIntegrationComponentSpec
implementation for theKafkaTemplate
.Modifier and TypeMethodDescriptionKafkaTemplateSpec.defaultTopic
(String defaultTopic) /** Set the default topic for send methods where a topic is not providing.KafkaTemplateSpec.messageConverter
(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter) Set the message converter to use.KafkaTemplateSpec.producerListener
(org.springframework.kafka.support.ProducerListener<K, V> producerListener) Set aProducerListener
which will be invoked when Kafka acknowledges a send operation.Modifier and TypeMethodDescriptionstatic <K,
V, R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K, V, R> Kafka.inboundGateway
(KafkaMessageListenerContainerSpec<K, V> containerSpec, KafkaTemplateSpec<K, R> templateSpec) Create an initialKafkaInboundGatewaySpec
with the provided container and template specs.Modifier and TypeMethodDescriptionKafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec.configureKafkaTemplate
(Consumer<KafkaTemplateSpec<K, V>> configurer) Configure a Kafka Template by invoking theConsumer
callback, with aKafkaTemplateSpec
argument.KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec.configureTemplate
(Consumer<KafkaTemplateSpec<K, R>> configurer) Configure a template by invoking theConsumer
callback, with aKafkaTemplateSpec
argument.