Package io.micronaut.configuration.kafka.seek

Interface KafkaSeeker

public interface KafkaSeeker
Performs seek operations on a target consumer.
Since:
4.1
Author:
Guillermo Calvo
See Also:

  • Method Details

    • newInstance

      @Internal @NonNull static @NonNull KafkaSeeker newInstance(@NonNull @NonNull Consumer<?,?> consumer)
      Creates a new KafkaSeeker with a given target Consumer.
      Parameters:
      consumer - the target consumer.
      Returns:
      a new kafka seeker.

    • perform

      boolean perform(@NonNull @NonNull KafkaSeekOperation operation)
      Performs a kafka seek operation immediately.
      Parameters:
      operation - the kafka seek operation to perform.
      Returns:
      whether the seek operation succeeded or not.