Class IncomingKafkaRecord<K,​T>

    • Constructor Detail

      • IncomingKafkaRecord

        public IncomingKafkaRecord​(io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<K,​T> consumer,
                                   io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<K,​T> record,
                                   KafkaFailureHandler onNack)
    • Method Detail

      • getPayload

        public T getPayload()
        Specified by:
        getPayload in interface Message<K>
        Returns:
        The payload for this message.
      • getHeaders

        public org.apache.kafka.common.header.Headers getHeaders()
        Specified by:
        getHeaders in interface KafkaRecord<K,​T>
      • getOffset

        public long getOffset()
      • getMetadata

        public Metadata getMetadata()
        Specified by:
        getMetadata in interface Message<K>
        Returns:
        The set of metadata attached to this message, potentially empty.
      • ack

        public CompletionStage<Void> ack()
        Description copied from interface: Message
        Acknowledge this message.
        Specified by:
        ack in interface Message<K>
        Returns:
        a completion stage completed when the message is acknowledged. If the acknowledgement fails, the completion stage propagates the failure.
      • nack

        public CompletionStage<Void> nack​(Throwable reason)
        Description copied from interface: Message
        Acknowledge negatively this message. nack is used to indicate that the processing of a message failed. The reason is passed as parameter.
        Specified by:
        nack in interface Message<K>
        Parameters:
        reason - the reason of the nack, must not be null
        Returns:
        a completion stage completed when the message is negative-acknowledgement has completed. If the negative acknowledgement fails, the completion stage propagates the failure.