Uses of Class
org.springframework.batch.item.kafka.builder.KafkaItemReaderBuilder
Package
Description
Builders for Apache Kafka item reader and writer.
-
Uses of KafkaItemReaderBuilder in org.springframework.batch.item.kafka.builder
Modifier 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 theItemStreamSupport
should be persisted within theExecutionContext
for restart purposes.A topic name to manually assign to the consumer.