confluent_kafka 从最新位点消费

`confluent_kafka`是一个由Confluent Inc.开发的高性能Apache Kafka客户端库，用于Java、Python等语言。如果你想从Kafka的最新位点（latest offset）开始消费消息，你可以按照以下步骤操作：

1. 创建消费者实例时，设置`auto.offset.reset`配置为`"earliest"`。这表示如果指定的偏移量不存在，将跳到最早的可用偏移量。因为`latest`通常指的是最新的消息，所以从最新的位点消费意味着消费队列中最新的消息。

Properties props = new Properties();
props.put("bootstrap.servers", "your-kafka-brokers");
props.put("group.id", "your-consumer-group");
props.put("enable.auto.commit", "true"); // 如果启用自动提交
props.put("auto.offset.reset", "earliest"); // 从最新位点开始

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

2. 加入主题并订阅：

consumer.subscribe(Arrays.asList("your-topic"));

然后，你可以通过`consumer.poll()`方法定期拉取消息，并处理它们。