org.springframework.integration.x.kafka

Class InitialOffsetsFactoryBean

java.lang.Object

org.springframework.integration.x.kafka.InitialOffsetsFactoryBean

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long>>

public class InitialOffsetsFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.FactoryBean<java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long>>

Parses the list of initial offsets and creates a map to initialize the OffsetManager

Author:

Marius Bogoevici, Ilayaperumal Gopinathan

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
InitialOffsetsFactoryBean(java.lang.String topics, java.lang.String initialOffsetList)

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long>	getObject()
java.lang.Class<?>	getObjectType()
boolean	isSingleton()

Methods inherited from class java.lang.Object

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

Field Detail

VALIDATION_PATTERN

public static final java.util.regex.Pattern VALIDATION_PATTERN

Constructor Detail

InitialOffsetsFactoryBean

public InitialOffsetsFactoryBean(java.lang.String topics,
                         java.lang.String initialOffsetList)

Method Detail

getObject

public java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long> getObject()
                                                                                             throws java.lang.Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long>>

Throws:

java.lang.Exception

getObjectType

public java.lang.Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long>>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<java.util.Map<org.springframework.integration.kafka.core.Partition,java.lang.Long>>