从 Confluent Kafka Schema Registry 中检索特定主题/模式答案

【问题标题】：Retrieving specific subjects/schema from Confluent Kafka Schema Registry从 Confluent Kafka Schema Registry 中检索特定主题/模式
【发布时间】：2022-12-24 08:56:22
【问题描述】：

我正在使用 Confluent Kafka Schema 注册表并定义了一些模式/主题。

几个例子：

  dev.delivery.kafka.delivery-reason-value
  dev.delivery.kafka.delivery-day-value
  dev.travel.kafka.places-ice-value

当我使用 confluent CLI 并连接到注册表时，我运行以下命令：

#this gives me all the subjects/schemas defined in the registry --perfectly fine :)
confluent schema-registry subject list --prefix ":*:"

但是，当我想检索特定主题的模式时，例如只有其中包含旅行词的模式

#this gives me "No Subjects."
confluent schema-registry subject list --prefix ":travel:"

要么

confluent schema-registry subject list --prefix ":*travel*:"

如果我在前缀中的通配符上遗漏了一些东西，有人可以在这里帮助我吗？

提前致谢

【问题讨论】：

Confluent CLI 是闭源的，所以不太确定它是如何工作的。我会直接在 /subjects 上使用 REST API 并解析响应。

标签： apache-kafka confluent-platform confluent-schema-registry confluent-cloud

【解决方案1】：

例如，这可以使用 Python 轻松完成。

import requests

r = requests.get('http://registry:8081/subjects')
for subject in r.json():
    if 'travel' in subject:  # example
      print(subject)

【讨论】：