auto.register.schemas=false时Kafka Streams无法向动态创建主题发消息

这更可能是预期行为，而非avro4k-kafka-serializer的Bug，具体原因如下：

1. Kafka Streams辅助主题的Schema处理逻辑
   Kafka Streams在执行repartition()、KTable关联等操作时，会自动创建repartition、changelog这类辅助主题，并且使用配置的默认序列化器处理消息。当auto.register.schemas=false时，无论是Confluent内置的SpecificAvroSerializer还是第三方的avro4k-kafka-serializer，都不会自动向Schema Registry注册这些辅助主题对应的Schema。

2. 「Subject not found」错误的触发原因
   序列化器发送消息前，会尝试从Schema Registry获取对应subject的Schema（subject命名规则一般为<辅助主题名>-key和<辅助主题名>-value）。由于这些subject并未提前注册，因此会抛出「Subject not found」错误。

3. 官方文档未提及的原因
   Confluent官方文档主要聚焦于用户显式创建的业务主题，并未针对Kafka Streams自动生成的辅助主题的Schema注册场景做详细说明，属于文档覆盖的遗漏点。

验证与解决方案建议 #

你可以尝试使用内置的SpecificAvroSerializer复现该场景，大概率会得到相同的错误。如果需要解决这个问题，有两种可行方案：

• 提前根据辅助主题的命名规则，手动向Schema Registry注册对应的Schema；
• 保持auto.register.schemas=true的默认配置，让序列化器自动完成Schema注册。

内容的提问来源于stack exchange，提问作者hertzsprung