代码之家 › 专栏 › 技术社区 › Mon Calamari

卡夫卡流拓扑在生产中的演变

apache-kafka-streams apache-kafka scala

0

Mon Calamari · 技术社区 · 7 年前

所有输入、中间和输出主题都是基于avro的主题。

我如何处理拓扑的更改(添加新步骤、新输入和输出主题),知道kafka streams维护内部状态和更改日志,并遵守以下业务要求:

kafka-streams-application-reset 或者创建全新的消费群体(应用程序id)?

1 回复 | 直到 7 年前

1

4

Nishu Tayal 7 年前

目前,Kafka流中没有检查点或保存点类型的概念。

application.id .

在某些情况下,您需要定义一个新的 应用程序id