パッケージ org.springframework.cloud.task.batch.autoconfigure.kafka

クラス KafkaItemReaderProperties

java.lang.ObjectSE
org.springframework.cloud.task.batch.autoconfigure.kafka.KafkaItemReaderProperties
@ConfigurationProperties(prefix="spring.batch.job.kafkaitemreader") public class KafkaItemReaderProperties extends ObjectSE
KafkaItemReader を構成するためのプロパティ。
導入:
2.3
作成者:
Glenn Renfro

  • コンストラクターのサマリー

    コンストラクター
    コンストラクター
    説明
    KafkaItemReaderProperties()

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    StringSE
    getName()
    ExecutionContext キーの計算に使用される名前の設定値を返します。
    ListSE<IntegerSE>
    getPartitions()
    コンシューマーに手動で割り当てるパーティションのリスト。
    long
    getPollTimeOutInSeconds()
    poll() 操作用の pollTimeout を取得します。
    StringSE
    getTopic()
    メッセージが読み取られるトピックの名前を返します。
    boolean
    isSaveState()
    再起動の目的で、ItemStreamSupport の状態を ExecutionContext 内に保持するかどうかを構成します。
    void
    setName(StringSE name)
    ExecutionContext 内のキーを計算するために使用される名前。
    void
    setPartitions(ListSE<IntegerSE> partitions)
    コンシューマーに手動で割り当てるパーティションのリスト。
    void
    setPollTimeOutInSeconds(long pollTimeOutInSeconds)
    poll() 操作用に pollTimeout を設定します。
    void
    setSaveState(boolean saveState)
    再起動の目的で、ItemStreamSupport の状態を ExecutionContext 内に保持するかどうかを構成します。
    void
    setTopic(StringSE topic)
    メッセージが読み取られるトピック名。

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

  • コンストラクターの詳細

    • KafkaItemReaderProperties

      public KafkaItemReaderProperties()

  • メソッドの詳細

    • getName

      public StringSE getName()
      ExecutionContext キーの計算に使用される名前の設定値を返します。
      戻り値:
      名前

    • setName

      public void setName(StringSE name)
      ExecutionContext 内のキーを計算するために使用される名前。
      パラメーター:
      name - ライターインスタンスの名前
      関連事項:
      • ItemStreamSupport.setName(String)

    • getTopic

      public StringSE getTopic()
      メッセージが読み取られるトピックの名前を返します。
      戻り値:
      トピックの名前。

    • setTopic

      public void setTopic(StringSE topic)
      メッセージが読み取られるトピック名。
      パラメーター:
      topic - トピック名

    • getPartitions

      public ListSE<IntegerSE> getPartitions()
      コンシューマーに手動で割り当てるパーティションのリスト。デフォルトでは、単一のエントリ値 1 になります。
      戻り値:
      パーティションのリスト。

    • setPartitions

      public void setPartitions(ListSE<IntegerSE> partitions)
      コンシューマーに手動で割り当てるパーティションのリスト。デフォルトでは、単一のエントリ値 1 になります。
      パラメーター:
      partitions - パーティションのリスト

    • getPollTimeOutInSeconds

      public long getPollTimeOutInSeconds()
      poll() 操作の pollTimeout を取得します。デフォルトは 30 秒です。
      戻り値:
      ポーリングタイムアウトを含む long。

    • setPollTimeOutInSeconds

      public void setPollTimeOutInSeconds(long pollTimeOutInSeconds)
      poll() 操作の pollTimeout を設定します。デフォルトは 30 秒です。
      パラメーター:
      pollTimeOutInSeconds - タイムアウトするまで待機する秒数。

    • isSaveState

      public boolean isSaveState()
      再起動の目的で ItemStreamSupport の状態を ExecutionContext 内に保持するかどうかを設定します。デフォルトは true です。
      戻り値:
      saveState フラグの現在のステータス。

    • setSaveState

      public void setSaveState(boolean saveState)
      再起動の目的で、ItemStreamSupport の状態を ExecutionContext 内に保持するかどうかを構成します。
      パラメーター:
      saveState - 状態を永続化する必要がある場合は true。デフォルトは true です。