io.micronaut.configuration.kafka

Interface KafkaAcknowledgement

All Superinterfaces:

io.micronaut.messaging.Acknowledgement

public interface KafkaAcknowledgement
extends io.micronaut.messaging.Acknowledgement

Defines an interface that can be injected into KafkaListener beans so that offsets can be manually committed.

Since:

1.1.0

Author:

James Kleeh

Method Summary

Modifier and Type	Method and Description
default void	nack() Kafka does not support rejection of messages explicitly.

Methods inherited from interface io.micronaut.messaging.Acknowledgement

ack

Method Detail

nack

default void nack()

Kafka does not support rejection of messages explicitly.

Specified by:

nack in interface io.micronaut.messaging.Acknowledgement

Throws:

java.lang.UnsupportedOperationException - if called