public class KafkaSourceModuleOptionsMetadata extends java.lang.Object implements ProfileNamesProvider
| 修飾子と型 | クラスと説明 |
|---|---|
static class | KafkaSourceModuleOptionsMetadata.OffsetStorageStrategy |
NO_PROFILES| コンストラクターと説明 |
|---|
KafkaSourceModuleOptionsMetadata() |
public void setTopic(java.lang.String topic)
public java.lang.String getTopic()
public void setTopics(java.lang.String topics)
public java.lang.String getTopics()
public java.lang.String getPartitions()
public void setPartitions(java.lang.String partitions)
public java.lang.String getInitialOffsets()
public void setInitialOffsets(java.lang.String initialOffsets)
public KafkaSourceModuleOptionsMetadata.OffsetStorageStrategy getOffsetStorage()
public void setOffsetStorage(KafkaSourceModuleOptionsMetadata.OffsetStorageStrategy offsetStorage)
public void setStreams(int streams)
public int getStreams()
public void setGroupId(java.lang.String groupId)
public java.lang.String getGroupId()
public void setEncoding(java.lang.String encoding)
public java.lang.String getEncoding()
public void setOffsetUpdateTimeWindow(int offsetUpdateTimeWindow)
public int getOffsetUpdateTimeWindow()
public void setOffsetUpdateCount(int offsetUpdateCount)
public int getOffsetUpdateCount()
public void setOffsetUpdateShutdownTimeout(int offsetUpdateShutdownTimeout)
public int getOffsetUpdateShutdownTimeout()
public void setQueueSize(int queueSize)
public int getQueueSize()
@AssertTrue(message="the options topic and topics are mutually exclusive") public boolean isTopicOptionValid()
@AssertTrue(message="explicit partitions can only be set when using single topic source") public boolean isPartitionsOptionValid()
@AssertTrue(message="initial offsets can only be set when using single topic source") public boolean isInitialOffsetsValid()
public java.lang.String[] profilesToActivate()
ProfileNamesProvider の profilesToActivate