コンストラクターの詳細

• KafkaItemReaderBuilder

  public KafkaItemReaderBuilder()

メソッドの詳細

• saveState

  public KafkaItemReaderBuilder<K,V> saveState(boolean saveState)

  再起動のために ItemStreamSupport の状態を ExecutionContext 内に保持する必要があるかどうかを構成します。

  パラメーター:

  saveState - デフォルトは true

  戻り値:

  ビルダーの現在のインスタンス。

• name

  public KafkaItemReaderBuilder<K,V> name(java.lang.String name)

  ExecutionContext 内でキーを計算するために使用される名前。saveState(boolean) が true に設定されている場合は必須です。

  パラメーター:

  name - リーダーインスタンスの名前

  戻り値:

  ビルダーの現在のインスタンス。

  関連事項:

  ItemStreamSupport.setName(String)

• consumerProperties

  public KafkaItemReaderBuilder<K,V> consumerProperties(java.util.Properties consumerProperties)

  基になるコンシューマープロパティを構成します。

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

  .

  パラメーター:

  consumerProperties - コンシューマーの特性

  戻り値:

  ビルダーの現在のインスタンス。

• partitions

  public KafkaItemReaderBuilder<K,V> partitions(java.lang.Integer... partitions)

  コンシューマーに手動で割り当てるパーティションのリスト。

  パラメーター:

  partitions - コンシューマーに割り当てるパーティションのリスト

  戻り値:

  ビルダーの現在のインスタンス。

• partitions

  public KafkaItemReaderBuilder<K,V> partitions(java.util.List<java.lang.Integer> partitions)

  コンシューマーに手動で割り当てるパーティションのリスト。

  パラメーター:

  partitions - コンシューマーに割り当てるパーティションのリスト

  戻り値:

  ビルダーの現在のインスタンス。

• partitionOffsets

  public KafkaItemReaderBuilder<K,V> partitionOffsets(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> partitionOffsets)

  パーティションオフセット用の Setter。このマッピングは、各パーティションで読み取りを開始するオフセットをリーダーに通知します。これはオプションであり、デフォルトでは各パーティションのオフセット 0 から始まります。空のマップを渡すと、リーダーは、コンシューマーグループ ID の Kafka に格納されているオフセットから開始します。

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

  パラメーター:

  partitionOffsets - 各パーティションの開始オフセットのマッピング

  戻り値:

  ビルダーの現在のインスタンス。

• topic

  public KafkaItemReaderBuilder<K,V> topic(java.lang.String topic)

  コンシューマーに手動で割り当てるトピック名。

  パラメーター:

  topic - コンシューマーに割り当てる名前

  戻り値:

  ビルダーの現在のインスタンス。

• pollTimeout

  public KafkaItemReaderBuilder<K,V> pollTimeout(java.time.Duration pollTimeout)

  poll() 操作の pollTimeout を設定します。デフォルトは 30 秒です。

  パラメーター:

  pollTimeout - ポーリング操作のタイムアウト

  戻り値:

  ビルダーの現在のインスタンス。

  関連事項:

  KafkaItemReader.setPollTimeout(Duration)

• build

  public KafkaItemReader<K,V> build()