Is this the part you need to dynamic.

return new KafkaItemReaderBuilder<Long, Customer>()

.partitions(0)

.consumerProperties(props)

.name("customers-reader")

.saveState(true)

.topic("demo")

.build();