我需要创建一个 Kafka 设置，在每天开始时，必须删除主题中的所有消息并将其偏移量重置为 0。
我试图通过将 log.retention 设置为 1 天来做到这一点，但它似乎没有用。我也跑了kafka-delete-records。它确实删除了所有消息，但kafka.tools.GetOffsetShell仍然给了我最新的偏移量。我希望它变为 0。
另外，我没有明确设置消费者组。它们是内部的，例如_confluent-ksql-default_transient_929377247691956102_1560973030312. 因此，无论消费者组如何，我都希望将主题的偏移量重置为 0。