我用Kafka编程Kafka消费者。我希望当我的消费者开始时，它只轮询新到达的消息（即消息在消费者开始时间之后到达），而不是消费者偏移量处的消息。

// Construct the configuration
Configuration config = {
    { "metadata.broker.list", "127.0.0.1:9092" },
    { "group.id", "1" },
    // Disable auto commit
    { "enable.auto.commit", false },
    // Set offest to latest to receive latest message when consumer start working
    { "auto.offset.reset", "latest" },
};

// Create the consumer
Consumer consumer(config);

consumer.set_assignment_callback([](TopicPartitionList& partitions) {
    cout << "Got assigned: " << partitions << endl;
});

// Print the revoked partitions on revocation
consumer.set_revocation_callback([](const TopicPartitionList& partitions) {
    cout << "Got revoked: " << partitions << endl;
});

string topic_name = "test_topic";
// Subscribe to the topic
consumer.subscribe({ topic_name });

据我所知，配置 auto.offset.reset 设置为 latest 仅当使用者在开始读取分配的分区时没有提交的偏移量时才起作用。所以我想我应该打电话给你 consumer.poll() 没有承诺，但感觉不对，我担心我会打破一些沿途。有人能告诉我怎样才能达到我的要求吗？