パッケージ org.springframework.batch.item.kafka.builder

クラス KafkaItemReaderBuilder<K,V>

java.lang.ObjectSE
org.springframework.batch.item.kafka.builder.KafkaItemReaderBuilder<K,V>
public class KafkaItemReaderBuilder<K,V> extends ObjectSE
KafkaItemReader のビルダー実装。
導入:
4.2
作成者:
Mathieu Ouellet, Mahmoud Ben Hassine
関連事項:

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

    • KafkaItemReaderBuilder

      public KafkaItemReaderBuilder()

  • メソッドの詳細

    • saveState

      public KafkaItemReaderBuilder<K,V> saveState(boolean saveState)
      再起動のために ItemStreamSupport の状態を ExecutionContext 内に保持する必要があるかどうかを構成します。
      パラメーター:
      saveState - デフォルトは true
      戻り値:
      ビルダーの現在のインスタンス。

    • name

      public KafkaItemReaderBuilder<K,V> name(StringSE name)
      ExecutionContext 内でキーを計算するために使用される名前。saveState(boolean) が true に設定されている場合は必須です。
      パラメーター:
      name - リーダーインスタンスの名前
      戻り値:
      ビルダーの現在のインスタンス。
      関連事項:

    • consumerProperties

      public KafkaItemReaderBuilder<K,V> consumerProperties(PropertiesSE consumerProperties)
      基になるコンシューマープロパティを構成します。

      consumerProperties には次のキーが含まれている必要があります: 'bootstrap.servers'、'group.id'、'key.deserializer' および 'value.deserializer'

      .
      パラメーター:
      consumerProperties - コンシューマーの特性
      戻り値:
      ビルダーの現在のインスタンス。

    • partitions

      public KafkaItemReaderBuilder<K,V> partitions(IntegerSE... partitions)
      コンシューマーに手動で割り当てるパーティションのリスト。
      パラメーター:
      partitions - コンシューマーに割り当てるパーティションのリスト
      戻り値:
      ビルダーの現在のインスタンス。

    • partitions

      public KafkaItemReaderBuilder<K,V> partitions(ListSE<IntegerSE> partitions)
      コンシューマーに手動で割り当てるパーティションのリスト。
      パラメーター:
      partitions - コンシューマーに割り当てるパーティションのリスト
      戻り値:
      ビルダーの現在のインスタンス。

    • partitionOffsets

      public KafkaItemReaderBuilder<K,V> partitionOffsets(MapSE<org.apache.kafka.common.TopicPartition,LongSE> partitionOffsets)
      パーティションオフセット用の Setter。このマッピングは、各パーティションで読み取りを開始するオフセットをリーダーに通知します。これはオプションであり、デフォルトでは各パーティションのオフセット 0 から始まります。空のマップを渡すと、リーダーは、コンシューマーグループ ID の Kafka に格納されているオフセットから開始します。

      再起動の場合、実行コンテキストに保存されているオフセットが優先されます。

      パラメーター:
      partitionOffsets - 各パーティションの開始オフセットのマッピング
      戻り値:
      ビルダーの現在のインスタンス。

    • topic

      public KafkaItemReaderBuilder<K,V> topic(StringSE topic)
      コンシューマーに手動で割り当てるトピック名。
      パラメーター:
      topic - コンシューマーに割り当てる名前
      戻り値:
      ビルダーの現在のインスタンス。

    • pollTimeout

      public KafkaItemReaderBuilder<K,V> pollTimeout(DurationSE pollTimeout)
      poll() 操作の pollTimeout を設定します。デフォルトは 30 秒です。
      パラメーター:
      pollTimeout - ポーリング操作のタイムアウト
      戻り値:
      ビルダーの現在のインスタンス。
      関連事項:

    • build

      public KafkaItemReader<K,V> build()