コンストラクターの詳細

• KafkaSourceModuleOptionsMetadata

  public KafkaSourceModuleOptionsMetadata()

メソッドの詳細

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

  次で指定:

  インターフェース ProfileNamesProvider の profilesToActivate