所以我是 Apache Kafka 的新手,我正在尝试创建一个简单的应用程序,以便我可以更好地理解 API。我知道这个问题在这里被问了很多,但是如何清除存储在主题上的消息/记录?
我看到的大多数答案都说要更改消息保留时间或删除并重新创建主题。这两个选项都不适合我,因为我无权访问 server.properties 文件。我没有在本地运行 Kafka,它托管在服务器上。有没有办法用Java代码来做到这一点?
如果您正在寻找一种有选择地删除消息的方法,新的 AdminClient API(可从 Java 代码中使用)提供以下功能deleteRecords
方法 :
https://kafka.apache.org/11/javadoc/org/apache/kafka/clients/admin/AdminClient.html https://kafka.apache.org/11/javadoc/org/apache/kafka/clients/admin/AdminClient.html
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)