Uses of Class
org.springframework.kafka.support.SendResult

Packages that use SendResult

Package	Description
org.springframework.kafka.core	Package for kafka core components
org.springframework.kafka.listener	Package for kafka listeners
org.springframework.kafka.requestreply	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 SendResult

Modifier and Type	Method	Description
protected CompletableFuture<SendResult<K,V>>	KafkaTemplate.doSend(org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord, io.micrometer.observation.Observation observation)	Send the producer record.
CompletableFuture<SendResult<K,V>>	KafkaOperations.send(String topic, Integer partition, Long timestamp, K key, V data)	Send the data to the provided topic with the provided key and partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations.send(String topic, Integer partition, K key, V data)	Send the data to the provided topic with the provided key and partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations.send(String topic, K key, V data)	Send the data to the provided topic with the provided key and no partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations.send(String topic, V data)	Send the data to the provided topic with no key or partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations.send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)	Send the provided ProducerRecord.
CompletableFuture<SendResult<K,V>>	KafkaOperations.send(Message<?> message)	Send a message with routing information in message headers.
CompletableFuture<SendResult<K,V>>	KafkaOperations2.send(String topic, Integer partition, Long timestamp, K key, V data)	Deprecated, for removal: This API element is subject to removal in a future version. Send the data to the provided topic with the provided key and partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations2.send(String topic, Integer partition, K key, V data)	Deprecated, for removal: This API element is subject to removal in a future version. Send the data to the provided topic with the provided key and partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations2.send(String topic, K key, V data)	Deprecated, for removal: This API element is subject to removal in a future version. Send the data to the provided topic with the provided key and no partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations2.send(String topic, V data)	Deprecated, for removal: This API element is subject to removal in a future version. Send the data to the provided topic with no key or partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations2.send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)	Deprecated, for removal: This API element is subject to removal in a future version. Send the provided ProducerRecord.
CompletableFuture<SendResult<K,V>>	KafkaOperations2.send(Message<?> message)	Deprecated, for removal: This API element is subject to removal in a future version. Send a message with routing information in message headers.
CompletableFuture<SendResult<K,V>>	KafkaTemplate.send(String topic, Integer partition, Long timestamp, K key, V data)
CompletableFuture<SendResult<K,V>>	KafkaTemplate.send(String topic, Integer partition, K key, V data)
CompletableFuture<SendResult<K,V>>	KafkaTemplate.send(String topic, K key, V data)
CompletableFuture<SendResult<K,V>>	KafkaTemplate.send(String topic, V data)
CompletableFuture<SendResult<K,V>>	KafkaTemplate.send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
CompletableFuture<SendResult<K,V>>	KafkaTemplate.send(Message<?> message)
CompletableFuture<SendResult<K,V>>	KafkaOperations.sendDefault(Integer partition, Long timestamp, K key, V data)	Send the data to the default topic with the provided key and partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations.sendDefault(Integer partition, K key, V data)	Send the data to the default topic with the provided key and partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations.sendDefault(K key, V data)	Send the data to the default topic with the provided key and no partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations.sendDefault(V data)	Send the data to the default topic with no key or partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations2.sendDefault(Integer partition, Long timestamp, K key, V data)	Deprecated, for removal: This API element is subject to removal in a future version. Send the data to the default topic with the provided key and partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations2.sendDefault(Integer partition, K key, V data)	Deprecated, for removal: This API element is subject to removal in a future version. Send the data to the default topic with the provided key and partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations2.sendDefault(K key, V data)	Deprecated, for removal: This API element is subject to removal in a future version. Send the data to the default topic with the provided key and no partition.
CompletableFuture<SendResult<K,V>>	KafkaOperations2.sendDefault(V data)	Deprecated, for removal: This API element is subject to removal in a future version. Send the data to the default topic with no key or partition.
CompletableFuture<SendResult<K,V>>	KafkaTemplate.sendDefault(Integer partition, Long timestamp, K key, V data)
CompletableFuture<SendResult<K,V>>	KafkaTemplate.sendDefault(Integer partition, K key, V data)
CompletableFuture<SendResult<K,V>>	KafkaTemplate.sendDefault(K key, V data)
CompletableFuture<SendResult<K,V>>	KafkaTemplate.sendDefault(V data)

Uses of SendResult in org.springframework.kafka.listener

Method parameters in org.springframework.kafka.listener with type arguments of type SendResult

Modifier and Type	Method	Description
protected 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 SendResult

Modifier and Type	Method	Description
CompletableFuture<SendResult<K,V>>	RequestReplyFuture.getSendFuture()	Return the send future.
CompletableFuture<SendResult<K,V>>	RequestReplyMessageFuture.getSendFuture()	Return the send future.

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

Modifier and Type	Method	Description
protected void	RequestReplyFuture.setSendFuture(CompletableFuture<SendResult<K,V>> sendFuture)