因此，我刚接触Apache Kafka，并试图创建一个简单的应用程序，以便可以更好地理解API。我知道在这里已经问过很多这个问题，但是如何清除存储在主题上的消息/记录？
我见过的大多数答案都是用来更改消息保留时间或删除并重新创建主题的。这些对我来说都不是选项，因为我无权访问server.properties文件。我不是在本地运行Kafka，而是在服务器上托管。有没有可能用Java代码或其他方式做到这一点？
如果您正在寻找一种选择性删除消息的方法，则新的AdminClient API（可从Java代码使用）提供以下deleteRecords方法：
https://kafka.apache.org/11/javadoc/org/apache/kafka/clients/admin/AdminClient.html
| 归档时间： |
|
| 查看次数： |
4323 次 |
| 最近记录： |