我试图了解 ConsumerConfig.auto.offset.reset = latest 如何影响消息消耗。
例如，我有一个消费者，最初在 t1 时间发送 100 条消息，然后我的消费者在 t1+30 秒启动并运行，然后我的消费者会消费 t1+30 秒后发布的消息还是会消费 t1 之后发布的消息?
apache-kafka
apache-kafka ×1