org.springframework.integration.x.kafka

Class SpringXdOffsetManager

java.lang.Object

org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

org.springframework.integration.x.kafka.SpringXdOffsetManager

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable, org.springframework.integration.kafka.listener.OffsetManager, DeletableOffsetManager

public class SpringXdOffsetManager
extends org.springframework.integration.kafka.listener.MetadataStoreOffsetManager
implements DeletableOffsetManager

Spring Integration Kafka MetadataStoreOffsetManager with additional features such as the ability to delete offsets, and recognizing Kafka consumer code for "earliest time" and "latest time" ("smallest" and "largest" respectively).

Author:

Marius Bogoevici

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SpringXdOffsetManager.AutoOffsetResetStrategy

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.regex.Pattern	VALIDATION_PATTERN

Constructor Summary

Constructors

Constructor and Description
SpringXdOffsetManager(org.springframework.integration.kafka.core.ConnectionFactory connectionFactory)
SpringXdOffsetManager(org.springframework.integration.kafka.core.ConnectionFactory connectionFactory, java.lang.String topic, java.lang.String initialOffsets) Creates a MetadataStoreOffsetManager with

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteOffset(org.springframework.integration.kafka.core.Partition partition) Removes the offset for a given Partition.
void	setAutoOffsetReset(SpringXdOffsetManager.AutoOffsetResetStrategy autoOffsetResetStrategy)

Methods inherited from class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

close, flush, getConsumerId, getMetadataStore, getOffset, getReferenceTimestamp, resetOffsets, setConsumerId, setMetadataStore, setReferenceTimestamp, updateOffset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.integration.kafka.listener.OffsetManager

getOffset, resetOffsets, updateOffset

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface java.io.Flushable

flush

Field Detail

VALIDATION_PATTERN

public static final java.util.regex.Pattern VALIDATION_PATTERN

Constructor Detail

SpringXdOffsetManager

public SpringXdOffsetManager(org.springframework.integration.kafka.core.ConnectionFactory connectionFactory)

SpringXdOffsetManager

public SpringXdOffsetManager(org.springframework.integration.kafka.core.ConnectionFactory connectionFactory,
                     java.lang.String topic,
                     java.lang.String initialOffsets)

Creates a MetadataStoreOffsetManager with

Parameters:

connectionFactory -

initialOffsets -

Method Detail

deleteOffset

public void deleteOffset(org.springframework.integration.kafka.core.Partition partition)

Description copied from interface: DeletableOffsetManager

Removes the offset for a given Partition.

Specified by:

deleteOffset in interface DeletableOffsetManager

setAutoOffsetReset

public void setAutoOffsetReset(SpringXdOffsetManager.AutoOffsetResetStrategy autoOffsetResetStrategy)