io.micronaut.configuration.kafka

Interface Acknowledgement

public interface Acknowledgement

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

Since:

1.0

Author:

graemerocher

Method Summary

Modifier and Type	Method and Description
void	ack() Acknowledge the last ConsumerRecord synchronously.

Method Detail

ack

void ack()

Acknowledge the last ConsumerRecord synchronously.