クラスの使用
org.springframework.batch.item.kafka.builder.KafkaItemReaderBuilder
org.springframework.batch.item.kafka.builder 内の KafkaItemReaderBuilder 使用
修飾子と型メソッド説明KafkaItemReaderBuilder.consumerProperties
(PropertiesSE consumerProperties) 基になるコンシューマープロパティを構成します。ExecutionContext
内でキーを計算するために使用される名前。KafkaItemReaderBuilder.partitionOffsets
(MapSE<org.apache.kafka.common.TopicPartition, LongSE> partitionOffsets) パーティションオフセット用の Setter。KafkaItemReaderBuilder.partitions
(IntegerSE... partitions) コンシューマーに手動で割り当てるパーティションのリスト。KafkaItemReaderBuilder.partitions
(ListSE<IntegerSE> partitions) コンシューマーに手動で割り当てるパーティションのリスト。KafkaItemReaderBuilder.pollTimeout
(DurationSE pollTimeout) poll() 操作用に pollTimeout を設定します。KafkaItemReaderBuilder.saveState
(boolean saveState) 再起動のためにItemStreamSupport
の状態をExecutionContext
内に保持する必要があるかどうかを構成します。コンシューマーに手動で割り当てるトピック名。