Uses of Class
org.springframework.kafka.core.KafkaTemplate
Package
Description
Package for kafka configuration
Package for kafka core components
Provides classes for adapting listeners.
Provides classes for request/reply semantics.
-
Uses of KafkaTemplate in org.springframework.kafka.config
Modifier and TypeMethodDescriptionprotected KafkaTemplate<?,
?> AbstractKafkaListenerEndpoint.getReplyTemplate()
Modifier and TypeMethodDescriptionvoid
AbstractKafkaListenerContainerFactory.setReplyTemplate
(KafkaTemplate<?, ?> replyTemplate) Set theKafkaTemplate
to use to send replies.void
AbstractKafkaListenerEndpoint.setReplyTemplate
(KafkaTemplate<?, ?> replyTemplate) Set theKafkaTemplate
to use to send replies. -
Uses of KafkaTemplate in org.springframework.kafka.core
Modifier and TypeClassDescriptionclass
AKafkaTemplate
that routes messages based on the topic name. -
Uses of KafkaTemplate in org.springframework.kafka.listener.adapter
Modifier and TypeMethodDescriptionvoid
MessagingMessageListenerAdapter.setReplyTemplate
(KafkaTemplate<?, ?> replyTemplate) Set the template to use to send any result from the method invocation. -
Uses of KafkaTemplate in org.springframework.kafka.requestreply
Modifier and TypeClassDescriptionclass
A replying template that aggregates multiple replies with the same correlation id.class
ReplyingKafkaTemplate<K,
V, R> A KafkaTemplate that implements request/reply semantics.