@KafkaListener(topics = "topics", errorHandler = "errorHandler", topicPartitions={
@TopicPartition(topic = "topic",
partitionOffsets = {
@PartitionOffset(partition = "0", initialOffset = "9760595"),
@PartitionOffset(partition = "1", initialOffset = "818000"),
@PartitionOffset(partition = "2", initialOffset = "819500")
}
)
})
public void xxxListener(@Payload String data, Acknowledgment acknowledgment) {
}



