Uses of Class
org.springframework.batch.item.kafka.builder.KafkaItemReaderBuilder
Packages that use KafkaItemReaderBuilder
Package
Description
Builders for Apache Kafka item reader and writer.
-
Uses of KafkaItemReaderBuilder in org.springframework.batch.item.kafka.builder
Methods in org.springframework.batch.item.kafka.builder that return KafkaItemReaderBuilderModifier and TypeMethodDescriptionKafkaItemReaderBuilder.consumerProperties(Properties consumerProperties) Configure the underlying consumer properties.The name used to calculate the key within theExecutionContext.KafkaItemReaderBuilder.partitionOffsets(Map<org.apache.kafka.common.TopicPartition, Long> partitionOffsets) Setter for partition offsets.KafkaItemReaderBuilder.partitions(Integer... partitions) A list of partitions to manually assign to the consumer.KafkaItemReaderBuilder.partitions(List<Integer> partitions) A list of partitions to manually assign to the consumer.KafkaItemReaderBuilder.pollTimeout(Duration pollTimeout) Set the pollTimeout for the poll() operations.KafkaItemReaderBuilder.saveState(boolean saveState) Configure if the state of theItemStreamSupportshould be persisted within theExecutionContextfor restart purposes.A topic name to manually assign to the consumer.