出现这个问题时,通常是因为没有正确配置Schema Registry的地址。以下是正确配置Schema Registry地址的示例代码:
ksql> SET 'schema.registry.url'='http://localhost:8081';
如果仍然无法解决问题,可能是数据生成时Avro格式出现了问题。请检查数据生成代码中使用的Schema是否正确。
另外,如果使用的是Confluent Platform,则需要使用Confluent的Schema Registry,而不是Apache Avro的默认Registry。
通过正确地配置Schema Registry地址和检查数据生成代码中使用的Schema,可以解决在ksql查询中看不到Avro数据的问题。
上一篇:Avro数据未转换为Spark