卡夫卡消费者从具体抵消

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

这段代码在循环中吗？据我所见，您首先进行轮询(因此获得实际消息(，然后寻求特定的偏移量。如果您不是在接收循环中执行此代码，则必须先查找，然后调用轮询以获取消息。