Kafka Streams 内部主题命名

Chr*_*ris 6 apache-kafka apache-kafka-streams

根据文档(https://docs.confluence.io/current/streams/developer-guide/manage-topics.html#internal-topics),内部主题遵循命名约定<application.id>-<operatorName>-<suffix>

我们有一些例子:

testapplication-KSTREAM-REDUCE-STATE-STORE-0000000008-repartition  
testapplication-KSTREAM-REDUCE-STATE-STORE-0000000027-repartition  
Run Code Online (Sandbox Code Playgroud)

有谁知道整数是如何确定的?

不幸的是,我们的安全要求不允许我们使用我们的应用程序创建主题,并且需要提前设置。我正在尝试确定这些主题名称是否一致。

Nis*_*yal 2

通常中间主题名称是按照以下约定构造的:

<ApplicationId>-<operator name>-<suffix>
Run Code Online (Sandbox Code Playgroud)

后缀值可以是“changelog”或“repartition”

根据运算符,它使用后缀之一。这是一个例子:

测试应用程序聚合重新分区

测试应用程序聚合变更日志