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()
java.lang.String	getPartitions()
int	getStreams()
java.lang.String	getTopic()
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	setPartitions(java.lang.String partitions)
void	setStreams(int streams)
void	setTopic(java.lang.String topic)

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()

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()

profilesToActivate

public java.lang.String[] profilesToActivate()

Specified by:

profilesToActivate in interface ProfileNamesProvider