クラスの使用
org.springframework.batch.item.kafka.builder.KafkaItemReaderBuilder
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内に保持する必要があるかどうかを構成します。コンシューマーに手動で割り当てるトピック名。