Uses of Class
org.springframework.kafka.support.SendResult
Package
Description
Package for kafka core components
Package for kafka listeners
Provides classes for request/reply semantics.
-
Uses of SendResult in org.springframework.kafka.core
Modifier and TypeMethodDescriptionprotected CompletableFuture<SendResult<K,
V>> KafkaTemplate.doSend
(org.apache.kafka.clients.producer.ProducerRecord<K, V> producerRecord, io.micrometer.observation.Observation observation) Send the producer record.Send the data to the provided topic with the provided key and partition.Send the data to the provided topic with the provided key and partition.Send the data to the provided topic with the provided key and no partition.Send the data to the provided topic with no key or partition.Send the providedProducerRecord
.Send a message with routing information in message headers.KafkaOperations.sendDefault
(Integer partition, Long timestamp, K key, V data) Send the data to the default topic with the provided key and partition.KafkaOperations.sendDefault
(Integer partition, K key, V data) Send the data to the default topic with the provided key and partition.KafkaOperations.sendDefault
(K key, V data) Send the data to the default topic with the provided key and no partition.KafkaOperations.sendDefault
(V data) Send the data to the default topic with no key or partition.KafkaTemplate.sendDefault
(Integer partition, Long timestamp, K key, V data) KafkaTemplate.sendDefault
(Integer partition, K key, V data) KafkaTemplate.sendDefault
(K key, V data) KafkaTemplate.sendDefault
(V data) -
Uses of SendResult in org.springframework.kafka.listener
Modifier and TypeMethodDescriptionprotected void
DeadLetterPublishingRecoverer.verifySendResult
(KafkaOperations<Object, Object> kafkaTemplate, org.apache.kafka.clients.producer.ProducerRecord<Object, Object> outRecord, CompletableFuture<SendResult<Object, Object>> sendResult, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> inRecord) Wait for the send future to complete. -
Uses of SendResult in org.springframework.kafka.requestreply
Modifier and TypeMethodDescriptionRequestReplyFuture.getSendFuture()
Return the send future.RequestReplyMessageFuture.getSendFuture()
Return the send future.Modifier and TypeMethodDescriptionprotected void
RequestReplyFuture.setSendFuture
(CompletableFuture<SendResult<K, V>> sendFuture)