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

【问题标题】：How to reset kafka streams application using the java code?如何使用 java 代码重置 kafka 流应用程序？
【发布时间】：2021-05-31 08:57:29
【问题描述】：

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

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

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

【问题讨论】：

【解决方案1】：

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

【讨论】：

谢谢。这是一种常见的现象吗？在开发 Kafka 流应用程序时，人们在开发级做什么？就没有别的办法了吗？
我不确定我是否理解这个问题。您只会在开发时进行重置，而不是在应用程序完成后进行重置，除非拓扑最终处于错误状态......并且建议始终只使用 CLI 命令。有一个cleanUp() 方法，但它只会清空本地文件系统，而不是内部主题。