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)
有谁知道整数是如何确定的?
不幸的是,我们的安全要求不允许我们使用我们的应用程序创建主题,并且需要提前设置。我正在尝试确定这些主题名称是否一致。
通常中间主题名称是按照以下约定构造的:
<ApplicationId>-<operator name>-<suffix>
Run Code Online (Sandbox Code Playgroud)
后缀值可以是“changelog”或“repartition”
根据运算符,它使用后缀之一。这是一个例子:
测试应用程序聚合重新分区
测试应用程序聚合变更日志
归档时间: |
|
查看次数: |
7835 次 |
最近记录: |