ksqlDB 无法从 Schema Registry 获取数据答案

【问题标题】：ksqlDB can't get data from Schema RegistryksqlDB 无法从 Schema Registry 获取数据
【发布时间】：2021-12-19 08:56:27
【问题描述】：

案例：我在 Kafka 中有一个名为 some_table_prefix.table_name 的主题。数据使用 AVRO 序列化，但由于历史原因，我在名为 table_name-value 的架构注册表中记录了。

当我尝试设置 ksqlDB 流时

CREATE STREAM some_stream_name
WITH (KAFKA_TOPIC='some_table_prefix.table_name', VALUE_FORMAT='AVRO');

我收到错误Schema for message values on topic some_table_prefix.table_name does not exist in the Schema Registry.Subject: some_table_prefix.table_name-value。

我已正确集成架构注册表，对于其他主题一切正常。

那么，是否可以在创建 ksqlDB 流时指定 Schema Registry 记录名称或以其他方式解决此问题？

【问题讨论】：

标签： apache-kafka streaming confluent-platform confluent-schema-registry ksqldb

【解决方案1】：

如果你有一个名为table_name 的主题，它生成了 Avro（它会在注册表中自动创建table_name-value），那么这就是 ksqlDB 应该使用的内容。如果您通过自己发布架构手动创建该主题，而不匹配主题名称，那么这就是问题的一部分。

正如错误所说，它正在根据您提供的主题在注册表中查找特定主题。据我所知，不可能使用其他主题名称，因此解决方法是将旧主题的架构发布到新主题中

【讨论】：