Package org.springframework.kafka.requestreply

Interface ReplyingKafkaOperations<K,​V,​R>

  • Type Parameters:
    K - the key type.
    V - the outbound data type.
    R - the reply data type.
    All Known Implementing Classes:
    AggregatingReplyingKafkaTemplate, ReplyingKafkaTemplate
    public interface ReplyingKafkaOperations<K,​V,​R>
    Request/reply operations.
    Since:
    2.1.3
    Author:
    Gary Russell

    • Method Detail

      • sendAndReceive

        RequestReplyFuture<K,​V,​R> sendAndReceive​(org.apache.kafka.clients.producer.ProducerRecord<K,​V> record)
        Send a request and receive a reply with the default timeout.
        Parameters:
        record - the record to send.
        Returns:
        a RequestReplyFuture.

      • sendAndReceive

        RequestReplyFuture<K,​V,​R> sendAndReceive​(org.apache.kafka.clients.producer.ProducerRecord<K,​V> record,
                                                     @Nullable
                                                     java.time.Duration replyTimeout)
        Send a request and receive a reply.
        Parameters:
        record - the record to send.
        replyTimeout - the reply timeout; if null, the default will be used.
        Returns:
        a RequestReplyFuture.
        Since:
        2.3