クラス KafkaItemReaderBuilder<K,V>
java.lang.ObjectSE
org.springframework.batch.item.kafka.builder.KafkaItemReaderBuilder<K,V>
KafkaItemReader
のビルダー実装。- 導入:
- 4.2
- 作成者:
- Mathieu Ouellet, Mahmoud Ben Hassine
- 関連事項:
コンストラクターのサマリー
メソッドのサマリー
修飾子と型メソッド説明build()
consumerProperties
(PropertiesSE consumerProperties) 基になるコンシューマープロパティを構成します。ExecutionContext
内でキーを計算するために使用される名前。partitionOffsets
(MapSE<org.apache.kafka.common.TopicPartition, LongSE> partitionOffsets) パーティションオフセット用の Setter。partitions
(IntegerSE... partitions) コンシューマーに手動で割り当てるパーティションのリスト。partitions
(ListSE<IntegerSE> partitions) コンシューマーに手動で割り当てるパーティションのリスト。pollTimeout
(DurationSE pollTimeout) poll() 操作用に pollTimeout を設定します。saveState
(boolean saveState) 再起動のためにItemStreamSupport
の状態をExecutionContext
内に保持する必要があるかどうかを構成します。コンシューマーに手動で割り当てるトピック名。
コンストラクターの詳細
KafkaItemReaderBuilder
public KafkaItemReaderBuilder()
メソッドの詳細
saveState
再起動のためにItemStreamSupport
の状態をExecutionContext
内に保持する必要があるかどうかを構成します。- パラメーター:
saveState
- デフォルトは true- 戻り値:
- ビルダーの現在のインスタンス。
name
ExecutionContext
内でキーを計算するために使用される名前。saveState(boolean)
が true に設定されている場合は必須です。- パラメーター:
name
- リーダーインスタンスの名前- 戻り値:
- ビルダーの現在のインスタンス。
- 関連事項:
consumerProperties
基になるコンシューマープロパティを構成します。
.consumerProperties
には次のキーが含まれている必要があります: 'bootstrap.servers'、'group.id'、'key.deserializer' および 'value.deserializer'- パラメーター:
consumerProperties
- コンシューマーの特性- 戻り値:
- ビルダーの現在のインスタンス。
partitions
コンシューマーに手動で割り当てるパーティションのリスト。- パラメーター:
partitions
- コンシューマーに割り当てるパーティションのリスト- 戻り値:
- ビルダーの現在のインスタンス。
partitions
コンシューマーに手動で割り当てるパーティションのリスト。- パラメーター:
partitions
- コンシューマーに割り当てるパーティションのリスト- 戻り値:
- ビルダーの現在のインスタンス。
partitionOffsets
public KafkaItemReaderBuilder<K,V> partitionOffsets(MapSE<org.apache.kafka.common.TopicPartition, LongSE> partitionOffsets) パーティションオフセット用の Setter。このマッピングは、各パーティションで読み取りを開始するオフセットをリーダーに通知します。これはオプションであり、デフォルトでは各パーティションのオフセット 0 から始まります。空のマップを渡すと、リーダーは、コンシューマーグループ ID の Kafka に格納されているオフセットから開始します。再起動の場合、実行コンテキストに保存されているオフセットが優先されます。
- パラメーター:
partitionOffsets
- 各パーティションの開始オフセットのマッピング- 戻り値:
- ビルダーの現在のインスタンス。
topic
コンシューマーに手動で割り当てるトピック名。- パラメーター:
topic
- コンシューマーに割り当てる名前- 戻り値:
- ビルダーの現在のインスタンス。
pollTimeout
poll() 操作の pollTimeout を設定します。デフォルトは 30 秒です。- パラメーター:
pollTimeout
- ポーリング操作のタイムアウト- 戻り値:
- ビルダーの現在のインスタンス。
- 関連事項:
build