Uses of Class
org.springframework.kafka.support.SendResult
Packages that use 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
Methods in org.springframework.kafka.core that return types with arguments of type SendResultModifier 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
Method parameters in org.springframework.kafka.listener with type arguments of type SendResultModifier 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
Methods in org.springframework.kafka.requestreply that return types with arguments of type SendResultModifier and TypeMethodDescriptionRequestReplyFuture.getSendFuture()
Return the send future.RequestReplyMessageFuture.getSendFuture()
Return the send future.Method parameters in org.springframework.kafka.requestreply with type arguments of type SendResultModifier and TypeMethodDescriptionprotected void
RequestReplyFuture.setSendFuture
(CompletableFuture<SendResult<K, V>> sendFuture)