我正在使用kafka 2.4.1（confluent 5.4.1），并尝试使用新的外键连接功能实现一个ktable到ktable的连接。它在本地运行得很好，但是由于公司的政策，我必须设置主题名称：

a.join(b,
       keyExtractor,
       this::map,
       Named.as("joiner"),
       joinStore);

问题是
主题按预期创建：[application.id]-“joiner”-[后缀]
但是，在向schema注册表注册schema时，只有“joiner”—[后缀]用作主题。这是一个问题，因为公司策略要求将application.id设置为给定值。
是虫子吗？至少，此行为似乎与其他命名存储（物化的、分组的）不一致。
更新1：
显然这是一个已知的问题：https://issues.apache.org/jira/browse/kafka-9390 我会试着升级，看看能不能解决我的问题。
更新2：
从合流回购升级到kafka streams 5.5.1-css解决了这个问题。我将切换回apachekafka版本https://github.com/apache/kafka/pull/8574 是在那里发布的，因为它是阻塞问题。