我正在尝试从 Eventhub 命名空间中特定 Eventhub 的架构注册表中检索相关架构(在当前时间点)。我需要在订阅 EventHub 之前检索架构,因此我对其进行处理以在我尝试填充的数据存储中创建一个架构。
如果我有 schemaId,我知道如何检索架构(请参阅下面的 Java 代码),但是如果我有 EventHub 名称,我如何检索我需要查找的架构 ID?
byte[] schemaBytes = schemaRegistry.getSchema(schemaId).block().getDefinition().getBytes(StandardCharsets.UTF_8);
我能够根据给定的 schema id 检索 schema,当我订阅时可以从 Kafka 标头中提取该 schema,但我希望能够在不订阅给定的 EventHub/topic 的情况下检索 schema。