我需要创建一个Kafka设置，在每天开始的时候，一个主题中的所有消息都必须被删除，其偏移量重置为0。
我试图通过将log.retention设置为1天来实现这一点，但似乎不起作用。我也跑了 kafka-delete-records . 它确实删除了所有的信息，但是 kafka.tools.GetOffsetShell 还是给了我最新的补偿。我要它转到0。
另外，我没有明确设置一个消费群体。它们是内部的，比如 _confluent-ksql-default_transient_929377247691956102_1560973030312 . 因此，我希望主题的偏移量重置为0，而不考虑使用者组。