Uses of Class
org.springframework.integration.kafka.dsl.KafkaTemplateSpec
Packages that use KafkaTemplateSpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaTemplateSpec in org.springframework.integration.kafka.dsl
Subclasses of KafkaTemplateSpec in org.springframework.integration.kafka.dslModifier and TypeClassDescriptionstatic classAnIntegrationComponentSpecimplementation for theKafkaTemplate.Subclasses with type arguments of type KafkaTemplateSpec in org.springframework.integration.kafka.dslModifier and TypeClassDescriptionclassKafkaTemplateSpec<K,V> AnIntegrationComponentSpecimplementation for theKafkaTemplate.Methods in org.springframework.integration.kafka.dsl that return KafkaTemplateSpecModifier 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 aProducerListenerwhich will be invoked when Kafka acknowledges a send operation.Methods in org.springframework.integration.kafka.dsl with parameters of type KafkaTemplateSpecModifier and TypeMethodDescriptionstatic <K,V, R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec <K, V, R> Kafka.inboundGateway(KafkaMessageListenerContainerSpec<K, V> containerSpec, KafkaTemplateSpec<K, R> templateSpec) Create an initialKafkaInboundGatewaySpecwith the provided container and template specs.Method parameters in org.springframework.integration.kafka.dsl with type arguments of type KafkaTemplateSpecModifier and TypeMethodDescriptionKafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec.configureKafkaTemplate(Consumer<KafkaTemplateSpec<K, V>> configurer) Configure a Kafka Template by invoking theConsumercallback, with aKafkaTemplateSpecargument.KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec.configureTemplate(Consumer<KafkaTemplateSpec<K, R>> configurer) Configure a template by invoking theConsumercallback, with aKafkaTemplateSpecargument.