Kafka消息的消费问题，如何消费到历史数据

跟订报纸一样，当你从订阅报纸的那一刻，报社才知道你，后续的报纸才会发送给你（之前的不会给你），所以你需要优先启动消费者。

如果java想从头开始读取，可以将offset设置成最新的。

为了从头开始消费消息，你需要设置消费者组的偏移量策略。Kafka 提供了两个主要的偏移量重置策略：

• earliest: 从最早的偏移量开始读取消息。
• latest: 从最新的偏移量开始读取消息。

如：

properties.setProperty(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");