您好，我正在使用 Go 和 Kafka 编写服务，我需要实现一个删除所有端点，该端点将从特定主题中删除所有记录。但是我找不到合适的方法来做到这一点。我正在为 Kafka 使用 Sarama library。
到目前为止，我能找到实现全部删除的唯一两种方法是删除似乎不是处理此问题的有效方法的主题，第二种方法是使用 Sarama 库中的 DeleteRecords 函数，但是此函数删除偏移量小于相应分区给定偏移量的记录。这意味着我必须先获取最新的偏移量。
基本上，我正在寻找做这种事情的最佳方法。有人可以帮我吗？最佳实践是什么？也许我错过了一些东西。我真的很感激一些例子。谢谢！
【问题讨论】：
标签： go apache-kafka sarama
如果您想修剪所有消息，另一种方法是将主题的保留时间减少到一个较小的值（例如 100 毫秒）。等待代理从主题中删除所有记录，然后将主题保留设置为其原始值。操作方法如下。
首先，将保留时间设置为 100 毫秒。
kafka-configs --zookeeper localhost:2181 \
--entity-type topics \
--entity-name my-topic \
--alter --add-config retention.ms=100
替代解决方案：
删除主题并重新创建 不像前两种方法那样优雅，但在某些情况下它可能是一个更简单的解决方案（例如，如果主题创建是脚本化的）。
kafka-topics --bootstrap-server localhost:9092 \
--topic my-topic \
--delete
然后重新创建它：
kafka-topics --bootstrap-server localhost:9092 \
--topic my-topic \
--create \
--partitions <number_of_partitions> \
--replication-factor <replication_factor>
【讨论】：