听风ᵎ(•̀㉨•́)و ̑̑的主页

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

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

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

如：

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