Uses of Class
org.springframework.kafka.requestreply.CorrelationKey
Packages that use CorrelationKey
Package
Description
Provides classes for request/reply semantics.
-
Uses of CorrelationKey in org.springframework.kafka.requestreply
Methods in org.springframework.kafka.requestreply with parameters of type CorrelationKeyModifier and TypeMethodDescriptionprotected booleanAggregatingReplyingKafkaTemplate.handleTimeout(CorrelationKey correlationId, RequestReplyFuture<K, V, Collection<org.apache.kafka.clients.consumer.ConsumerRecord<K, R>>> future) protected booleanReplyingKafkaTemplate.handleTimeout(CorrelationKey correlationId, RequestReplyFuture<K, V, R> future) Used to inform subclasses that a request has timed out so they can clean up state and, optionally, complete the future.protected booleanReplyingKafkaTemplate.isPending(CorrelationKey correlationId) Return true if this correlation id is still active.protected voidReplyingKafkaTemplate.logLateArrival(org.apache.kafka.clients.consumer.ConsumerRecord<K, R> record, CorrelationKey correlationId) Method parameters in org.springframework.kafka.requestreply with type arguments of type CorrelationKeyModifier and TypeMethodDescriptionvoidReplyingKafkaTemplate.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.