apache-kafka - 有没有办法删除主题中的所有数据或在每次运行之前删除主题？

Question

有没有办法删除主题中的所有数据或在每次运行之前删除主题？

我可以修改 KafkaConfig.scala 文件来更改 logRetentionHours 属性吗？有没有办法在消费者阅读消息后立即将其删除？

我正在使用生产者从某处获取数据并将数据发送到消费者消费的特定主题，我可以在每次运行时删除该主题中的所有数据吗？我每次都只想要该主题中的新数据。有没有办法以某种方式重新初始化主题？

Answer 1

正如我在这里提到的 Purge Kafka Queue :

在 Kafka 0.8.2 中测试，快速启动示例:首先，在 config 文件夹下的 server.properties 文件中添加一行:

delete.topic.enable=true

然后，您可以运行以下命令:

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test