我有一个复杂的拓扑，包括 KStreams、KTables、连接、重新生成 key 、过滤器、直通、分支、zip 等，以及输出主题上的实时客户端。
所有输入、中间和输出主题都是基于 avro 的主题。
如何处理拓扑更改(添加新步骤、新输入-中间-输出主题)，了解 kafka-streams 维护内部状态和更改日志，并遵守以下业务要求:
- 无数据丢失
- 没有数据重复(在一定程度上)
- 无停机时间
答案是否介于使用kafka-streams-application-reset或创建全新的消费者组(应用程序ID)之间？
最佳答案
目前，Kafka Streams 中没有检查点或保存点类型概念。
如果您需要更新现有应用程序，可以安全地使用新的 application.id 或重置现有的 application.id。
在某些情况下，您需要根据拓扑的变化定义新的 application.id。
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Data+%28Re%29Processing+Scenarios
关于scala - 生产中 kafka-streams 拓扑的演变，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/53745289/