Чтение сообщений из темы Kafka между диапазоном смещений. ⇐ JAVA

[Anonymous]

Я ищу способ использовать некоторый набор сообщений из моей темы Kafka с определенным диапазоном смещения (предположим, что мой раздел имеет смещение от 200 до 300, я хочу использовать сообщения со смещением 250-270) .

Я использую приведенный ниже код, в котором могу указать начальное смещение, но оно будет поглощать все сообщения от 250 до конца. Есть ли какой-либо способ/атрибуты, позволяющие установить конечное смещение для использования сообщений до этого момента.



@KafkaListener(id = "KafkaListener",
topics = "${kafka.topic.name}",
containerFactory = "kafkaManualAckListenerContainerFactory",
errorHandler = "${kafka.error.handler}",
topicPartitions = @TopicPartition(topic = "${kafka.topic.name}",
partitionOffsets = {
@PartitionOffset(partition = "0", initialOffset = "250"),
@PartitionOffset(partition = "1", initialOffset = "250")
}))


Подробнее здесь: https://stackoverflow.com/questions/605 ... of-offsets