Uses of Class
org.springframework.kafka.requestreply.CorrelationKey
Package
Description
Provides classes for request/reply semantics.
-
Uses of CorrelationKey in org.springframework.kafka.requestreply
Modifier and TypeMethodDescriptionvoid
ReplyingKafkaTemplate.setCorrelationIdStrategy
(Function<org.apache.kafka.clients.producer.ProducerRecord<K, V>, CorrelationKey> correlationStrategy) Set a function to be called to establish a unique correlation key for each request record.