无论消费者组如何，删除消息并将主题偏移量重置为 0

Question

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

我试图通过将 log.retention 设置为 1 天来做到这一点，但它似乎没有用。我还跑了kafka-delete-records。它确实删除了所有消息，但kafka.tools.GetOffsetShell 仍然给了我最新的偏移量。我希望它变为 0。

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

Answer 1

在Kafka中没有办法重置主题的头部偏移量，只能删除该主题并创建一个具有相同名称的新主题。

您也可以使用 admin api 删除消费者组。