kafka-streams 2.5.0 不支持在reduce上命名？

Question

---

嗨， 我需要为在 kafka-streams 中创建的内部/中间主题提供自定义名称。

但是，只有“*repartitioned”主题被重命名，而“aggregate”主题没有被重命名。

好像 kafka-streams 2.5.0 不支持 Named on reduce？

我配置了它，但它没有使用它。分组的主题使用命名的并查看具有该名称的重新分区主题，但减少的主题不使用该名称。

为了能够在浏览状态商店进行查询时很好地演示 Azkarra 流。

---

更新： 你好卡夫卡社区， 我了解，我使用的 Named 参数用于配置用于命名拓扑中的处理器， 但是有什么方法可以给像 kstream-aggregate-... 这样的中间主题一个自定义的、更易读的名称？ 谢谢

Answer 1

应该可以命​​名所有处理器/存储/主题。

但是，API 的工作原理并不总是很清楚——事实上，有些 Named 参数“重叠”。这是一个已知问题，没有很好的记录。 我们需要在某个时候解决这个问题。

如果你想命名一个changelog主题，你可以命名对应的 商店，通过Materialized，商店名称将被重用于 更改日志主题。

如果你想命名一个重新分区的主题，你可以通过 GroupedgroupBy()或groupByKey()的参数。