我正在使用sarama-cluster（由Golang kafka消费者客户端编写）
在代理中，我的主题的分区偏移量是11000，我的消费者组的分区偏移量是10100.然后我运行我的集群消费者，但没有消耗。 （消耗时间为1~2天后）
但是当我在主题的分区中生成消息时，它消耗了！ （在每个分区中）
许多消息是901.为什么我的消费者群集消费似乎在生成消息时激活？
我的消费者设置是auto.offset.reset = latest
这是因为您的偏移重置设置。 auto.offset.reset = latest意味着您的消费者群体应该等待最新的记录。如果你想从头开始消费，请使用auto.offset.reset = earliest。