如何禁用Kafka Streams中外键关联的*-subscription-store-changelog主题创建？

你遇到的问题核心在于：传入join()方法的Materialized.withLoggingDisabled()只控制关联结果状态存储的Changelog，而报错中的subscription-store-changelog是Kafka Streams为外键关联专门创建的订阅状态存储的日志主题，这个存储的配置不受当前Materialized参数的管控。

解决方案 #

有两种方式可以禁用该订阅存储的Changelog主题创建：

1. 全局禁用所有订阅存储的Changelog

在构建StreamsConfig时添加专属配置，一次性禁用所有外键关联的订阅存储日志：

Properties streamsProps = new Properties();
// 其他Kafka Streams常规配置（如bootstrap.servers、application.id等）
streamsProps.put(StreamsConfig.SUBSCRIPTION_STORE_CHANGE_LOG_ENABLE_CONFIG, false);

KafkaStreams streams = new KafkaStreams(topology, streamsProps);

2. 针对特定关联操作禁用Changelog

如果只想禁用当前名为dummy-topic的关联操作的订阅存储日志，可以通过命名前缀配置实现：

Properties streamsProps = new Properties();
// 其他常规配置
// 针对名为"dummy-topic"的关联，禁用其订阅存储的Changelog
streamsProps.put(
    StreamsConfig.TOPIC_PREFIX + "dummy-topic-subscription-store" + StreamsConfig.CHANGE_LOG_ENABLE_CONFIG,
    false
);

为什么之前的方法无效 #

KTable与KTable的外键关联过程中，Kafka Streams会创建三类状态存储：

• 左表的状态存储
• 右表的状态存储
• 订阅状态存储：用于跟踪左表中外键到主键的映射关系，实现外键关联的匹配逻辑

你传入的Materialized参数仅作用于关联结果生成的新KTable对应的状态存储，而订阅状态存储属于Kafka Streams内部维护的独立存储，因此需要通过专门的配置项来控制其Changelog开关。

内容的提问来源于stack exchange，提问作者R K 0