io.micronaut.configuration.kafka.annotation

Enum OffsetStrategy

java.lang.Object

java.lang.Enum<OffsetStrategy>

io.micronaut.configuration.kafka.annotation.OffsetStrategy

All Implemented Interfaces:

java.io.Serializable, java.lang.Comparable<OffsetStrategy>

public enum OffsetStrategy
extends java.lang.Enum<OffsetStrategy>

An enum representing different strategies for committing offsets to Kafka when using KafkaListener.

To track records that have been consumed Kafka allows committing offsets at a frequency desired by the developer. This tracking is done by committing offsets for a given partition back to Kafka.

Depending on requirements you may wish the commit more or less frequently and you may not care whether the commit was successful or not. This enum allows configuring a range of policies for a Kafka consumer from leaving it down to the Kafka client (with {code AUTO}) to synchronously committing offsets after each consumer record is consumed.

Since:

1.0

Author:

Graeme Rocher

Enum Constant Summary

Enum Constants

Enum Constant and Description
ASYNC Asynchronously commit offsets using Consumer.commitAsync() after each batch of messages is processed.
ASYNC_PER_RECORD Asynchronously commit offsets using Consumer.commitSync() after each ConsumerRecord is consumed.
AUTO Automatically commit offsets with the Consumer.poll(long) loop.
DISABLED Do not commit offsets.
SYNC Synchronously commit offsets using Consumer.commitSync() after each batch of messages is processed.
SYNC_PER_RECORD Synchronously commit offsets using Consumer.commitSync() after each ConsumerRecord is consumed.

Method Summary

Modifier and Type	Method and Description
static OffsetStrategy	valueOf(java.lang.String name) Returns the enum constant of this type with the specified name.
static OffsetStrategy[]	values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Detail

AUTO

public static final OffsetStrategy AUTO

Automatically commit offsets with the Consumer.poll(long) loop.

DISABLED

public static final OffsetStrategy DISABLED

Do not commit offsets. In this case the consumer method should accept an argument that is the KafkaConsumer itself and call KafkaConsumer.commitSync().

SYNC

public static final OffsetStrategy SYNC

Synchronously commit offsets using Consumer.commitSync() after each batch of messages is processed.

ASYNC

public static final OffsetStrategy ASYNC

Asynchronously commit offsets using Consumer.commitAsync() after each batch of messages is processed.

SYNC_PER_RECORD

public static final OffsetStrategy SYNC_PER_RECORD

Synchronously commit offsets using Consumer.commitSync() after each ConsumerRecord is consumed.

ASYNC_PER_RECORD

public static final OffsetStrategy ASYNC_PER_RECORD

Asynchronously commit offsets using Consumer.commitSync() after each ConsumerRecord is consumed.

Method Detail

values

public static OffsetStrategy[] values()

Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:

for (OffsetStrategy c : OffsetStrategy.values())
    System.out.println(c);

Returns:

an array containing the constants of this enum type, in the order they are declared

valueOf

public static OffsetStrategy valueOf(java.lang.String name)

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

java.lang.IllegalArgumentException - if this enum type has no constant with the specified name

java.lang.NullPointerException - if the argument is null