Package io.micronaut.configuration.kafka.seek

Interface KafkaSeekOperations

All Superinterfaces:

Iterable<KafkaSeekOperation>

public interface KafkaSeekOperations
extends Iterable<KafkaSeekOperation>

Defines an interface that can be injected into KafkaListener beans so that seek operations can be eventually performed on a consumer.

The operations will be performed by Micronaut automatically, when the consumer method completes successfully, possibly after committing offsets via OffsetStrategy.AUTO.

Since:

4.1

Author:

Guillermo Calvo

See Also:

• KafkaSeekOperation

Method Summary

Modifier and Type	Method	Description
void	defer(@NonNull KafkaSeekOperation operation)	Adds a KafkaSeekOperation to the list.
static @NonNull KafkaSeekOperations	newInstance()	Creates a new KafkaSeekOperations instance.

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Method Details

newInstance

@Internal
@NonNull
static @NonNull KafkaSeekOperations newInstance()

Creates a new KafkaSeekOperations instance.

Returns:

a new instance.

defer

void defer(@NonNull
 @NonNull KafkaSeekOperation operation)

Adds a KafkaSeekOperation to the list.

Parameters:

operation - the kafka seek operation to eventually perform.