Кафка потребителя со специфического смещения

Question

Вот код, но у меня нет правильных данных о результатах, которые поступают неправильно из определенного смещения. Что делать, пожалуйста, дайте мне знать, если кто-нибудь знает

ConsumerRecords<String, AccountHolder> records = consumer.poll(Duration.ofSeconds(1000));

        if (flag) {
            //consumer.seek(new TopicPartition("sudotest", 0), 29061);
            consumer.seek(new TopicPartition("sudotest",0), 2854);


            flag = false;
        }

        for (ConsumerRecord<String, AccountHolder> record : records)
            System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
    }
}

Answer 1

Этот код внутри цикла? Из того, что я вижу, вы сначала опрашиваете (таким образом, получаете реальные сообщения), а затем вы стремитесь к определенному смещению. Если вы не выполняете этот код в цикле приема, сначала нужно выполнить поиск, а затем вызвать опрос для получения сообщений.