删除消息，并且将主题偏移量重置为0，而不考虑消费者组

Question

我需要创建一个Kafka设置，其中在每天开始时，必须删除主题中的所有消息并将其偏移量重置为0。

我已经尝试通过将log.retention设置为1天来执行此操作，但是它似乎没有用。我也跑了kafka-delete-records。它确实删除了所有消息，但kafka.tools.GetOffsetShell仍然给了我最新的偏移量。我希望它转到0。

此外，我也没有明确设置消费者群体。它们是内部变量，例如_confluent-ksql-default_transient_929377247691956102_1560973030312。因此，我希望将该主题的偏移量重置为0，而与消费者组无关。

我需要创建一个Kafka安装程序，在每天的开始，必须删除主题中的所有消息并将其偏移量重置为0。我试图通过将log.retention设置为1天来做到这一点，但是它.. 。

Answer 1

除了删除主题并创建一个具有相同名称的主题外，无法在Kafka中重置主题的头部偏移。