因此，我对使用apachekafka还很陌生，我正在尝试创建一个简单的应用程序，以便更好地理解api。我知道这个问题在这里被问了很多，但是我怎样才能清除存储在某个主题上的消息/记录呢？
我看到的大多数答案都是更改消息保留时间或删除并重新创建主题。这两个都不是我的选项，因为我无权访问server.properties文件。我不是在本地运行Kafka，它是在服务器上托管的。有没有一种方法可以用java代码或者别的什么来实现呢？
因此，我对使用apachekafka还很陌生，我正在尝试创建一个简单的应用程序，以便更好地理解api。我知道这个问题在这里被问了很多，但是我怎样才能清除存储在某个主题上的消息/记录呢？
我看到的大多数答案都是更改消息保留时间或删除并重新创建主题。这两个都不是我的选项，因为我无权访问server.properties文件。我不是在本地运行Kafka，它是在服务器上托管的。有没有一种方法可以用java代码或者别的什么来实现呢？
1条答案
按热度按时间nbysray51#
如果您正在寻找有选择地删除消息的方法，那么新的adminclientapi（可从java代码中使用）提供了以下内容
deleteRecords方法：https://kafka.apache.org/11/javadoc/org/apache/kafka/clients/admin/adminclient.html