Uses of Class
org.springframework.kafka.requestreply.CorrelationKey

Packages that use CorrelationKey

Package	Description
org.springframework.kafka.requestreply	Provides classes for request/reply semantics.

Uses of CorrelationKey in org.springframework.kafka.requestreply

Methods in org.springframework.kafka.requestreply with parameters of type CorrelationKey

Modifier and Type	Method	Description
protected boolean	AggregatingReplyingKafkaTemplate.handleTimeout(CorrelationKey correlationId, RequestReplyFuture<K,V,Collection<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>> future)
protected boolean	ReplyingKafkaTemplate.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 boolean	ReplyingKafkaTemplate.isPending(CorrelationKey correlationId)	Return true if this correlation id is still active.
protected void	ReplyingKafkaTemplate.logLateArrival(org.apache.kafka.clients.consumer.ConsumerRecord<K,R> record, CorrelationKey correlationId)

Method parameters in org.springframework.kafka.requestreply with type arguments of type CorrelationKey

Modifier and Type	Method	Description
void	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.