org.springframework.integration.x.kafka

Class KafkaSourceModuleOptionsMetadata

java.lang.Object

org.springframework.integration.x.kafka.KafkaSourceModuleOptionsMetadata

All Implemented Interfaces:

ProfileNamesProvider

public class KafkaSourceModuleOptionsMetadata
extends java.lang.Object
implements ProfileNamesProvider

Module options for Kafka source module.

Author:

Ilayaperumal Gopinathan, Marius Bogoevici

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaSourceModuleOptionsMetadata.OffsetStorageStrategy

Field Summary

Fields inherited from interface org.springframework.xd.module.options.spi.ProfileNamesProvider

NO_PROFILES

Constructor Summary

Constructors

Constructor and Description
KafkaSourceModuleOptionsMetadata()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getEncoding()
java.lang.String	getGroupId()
java.lang.String	getInitialOffsets()
KafkaSourceModuleOptionsMetadata.OffsetStorageStrategy	getOffsetStorage()
int	getOffsetUpdateCount()
int	getOffsetUpdateShutdownTimeout()
int	getOffsetUpdateTimeWindow()
java.lang.String	getPartitions()
int	getQueueSize()
int	getStreams()
java.lang.String	getTopic()
java.lang.String	getTopics()
boolean	isInitialOffsetsValid()
boolean	isPartitionsOptionValid()
boolean	isTopicOptionValid()
java.lang.String[]	profilesToActivate()
void	setEncoding(java.lang.String encoding)
void	setGroupId(java.lang.String groupId)
void	setInitialOffsets(java.lang.String initialOffsets)
void	setOffsetStorage(KafkaSourceModuleOptionsMetadata.OffsetStorageStrategy offsetStorage)
void	setOffsetUpdateCount(int offsetUpdateCount)
void	setOffsetUpdateShutdownTimeout(int offsetUpdateShutdownTimeout)
void	setOffsetUpdateTimeWindow(int offsetUpdateTimeWindow)
void	setPartitions(java.lang.String partitions)
void	setQueueSize(int queueSize)
void	setStreams(int streams)
void	setTopic(java.lang.String topic)
void	setTopics(java.lang.String topics)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSourceModuleOptionsMetadata

public KafkaSourceModuleOptionsMetadata()

Method Detail

setTopic

public void setTopic(java.lang.String topic)

getTopic

public java.lang.String getTopic()

setTopics

public void setTopics(java.lang.String topics)

getTopics

public java.lang.String getTopics()

getPartitions

public java.lang.String getPartitions()

setPartitions

public void setPartitions(java.lang.String partitions)

getInitialOffsets

public java.lang.String getInitialOffsets()

setInitialOffsets

public void setInitialOffsets(java.lang.String initialOffsets)

getOffsetStorage

public KafkaSourceModuleOptionsMetadata.OffsetStorageStrategy getOffsetStorage()

setOffsetStorage

public void setOffsetStorage(KafkaSourceModuleOptionsMetadata.OffsetStorageStrategy offsetStorage)

setStreams

public void setStreams(int streams)

getStreams

public int getStreams()

setGroupId

public void setGroupId(java.lang.String groupId)

getGroupId

public java.lang.String getGroupId()

setEncoding

public void setEncoding(java.lang.String encoding)

getEncoding

public java.lang.String getEncoding()

setOffsetUpdateTimeWindow

public void setOffsetUpdateTimeWindow(int offsetUpdateTimeWindow)

getOffsetUpdateTimeWindow

public int getOffsetUpdateTimeWindow()

setOffsetUpdateCount

public void setOffsetUpdateCount(int offsetUpdateCount)

getOffsetUpdateCount

public int getOffsetUpdateCount()

setOffsetUpdateShutdownTimeout

public void setOffsetUpdateShutdownTimeout(int offsetUpdateShutdownTimeout)

getOffsetUpdateShutdownTimeout

public int getOffsetUpdateShutdownTimeout()

setQueueSize

public void setQueueSize(int queueSize)

getQueueSize

public int getQueueSize()

isTopicOptionValid

@AssertTrue(message="the options topic and topics are mutually exclusive")
public boolean isTopicOptionValid()

isPartitionsOptionValid

@AssertTrue(message="explicit partitions can only be set when using single topic source")
public boolean isPartitionsOptionValid()

isInitialOffsetsValid

@AssertTrue(message="initial offsets can only be set when using single topic source")
public boolean isInitialOffsetsValid()

profilesToActivate

public java.lang.String[] profilesToActivate()

Specified by:

profilesToActivate in interface ProfileNamesProvider