kafka offsetreset

Kafka的offset reset是指当一个消费者加入一个消费者组时，或者一个消费者在消费过程中出现了异常导致无法从上一个offset继续消费时，如何确定消费的起始位置。在这种情况下，Kafka提供了两种offset reset的方式：

1. earliest：从最早的消息开始消费。这意味着消费者将从最早的可用消息开始消费，即从分区的第一个偏移量开始。这种方式适用于消费者希望从头开始消费整个主题的情况。

2. latest：从最新的消息开始消费。这意味着消费者将从最新可用消息开始消费，即从分区的末尾偏移量开始消费。这种方式适用于消费者希望只消费最新的消息而不是历史消息的情况。

您可以通过设置auto.offset.reset属性来指定offset reset的方式，如果您没有指定该属性，则默认值为latest。例如，在使用Java客户端时，您可以通过以下方式设置auto.offset.reset属性：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-group");
props.put("auto.offset.reset", "earliest");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

这将使消费者从最早可用的消息开始消费。