如何使用java代码重置kafka流应用程序

Question

我想删除所有中间主题并重新处理数据。在开发的时候，我用这个命令重新启动；

docker exec -i containerName kafka-streams-application-reset.sh --bootstrap-servers :9092  --application-id  appid1

但是，当使用多个应用程序时，会导致重复执行不必要的步骤。我想在运行Java应用程序之前执行此操作吗？有可能吗？

Answer 1

kafka-streams-application-reset.sh只是Scala类的外壳包装器，您可以从代码中导入和调用它，当然

https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/tools/StreamsResetter.java