我有使用流1.1.1（计划升级到2.1推出），即合计发布记录压实主题（“客户事件”），通过下游的微服务作为其输入KTable消耗一个微服务。
这最终建立两个主题与同一信息的精确副本。 “客户事件”之一;另一种是在幕后创建找回状态商店内部之一。这两个有相同的键和值。
有没有办法要么 -
A）优化内部主题命名约定，这样我们就可以简单的使用状态存储后盾的changelog话题，因为我们的微服务输入的话题，但不要害怕版本将打破命名约定？
要么
B）禁用日志记录状态存储，如果状态存储必须被重新修建，迫使它使用“客户事件”话题，因为它的输入。 （首选）
唯一觉得你可以做的，是将数据写不进通过to()水槽的话题，让直接从无论如何创建changelog的主题阅读下游消费。如果命名KTable通过Materialized.as(...)参数，更改日志主题的名称将使用它作为更新日志主题名称的组成部分（这是不可能的，指定的changelog主题的全名）。命名KTable提供兼容性，例如，如果你升级你的应用程序的名称不会改变。
重用输出话题，省略changelog的话题是我们计划添加到卡夫卡流在未来，但（参见https://issues.apache.org/jira/browse/KAFKA-6035）的优化。
如果禁用日志记录，你可以使用容错担保，因此，这似乎不是一个选项。