Package io.smallrye.reactive.messaging.kafka.reply

Interface PendingReply

All Known Implementing Classes:
KafkaRequestReplyImpl.PendingReplyImpl
public interface PendingReply
A pending reply for a request.

  • Method Details

    • replyTopic

      String replyTopic()
      Returns:
      reply topic

    • replyPartition

      int replyPartition()
      Returns:
      reply partition, -1 if not set

    • recordMetadata

      org.apache.kafka.clients.producer.RecordMetadata recordMetadata()
      Returns:
      the recordMetadata of the request

    • complete

      void complete()
      Complete the pending reply.

    • isCancelled

      boolean isCancelled()
      Returns:
      whether the pending reply was terminated (with a completion or failure).