如何使用ksql将kafka集群中的所有主题存储到另一个主题

n3ipq98p  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(448)

我是ksql的新手。我想使用ksql查询将kafka集群中的所有主题名称存储到另一个主题。 SHOW TOPICS; 来自ksql的cli提供了主题列表。我想通过创建一个流将所有这些主题信息存储在另一个主题中。我将轮询这个新主题(使用使用者),每当在集群中创建新主题时,我的使用者将收到一条消息。我需要一个ksql查询来完成这个任务。
提前谢谢。

klr1opcd

klr1opcd1#

您目前无法使用ksqldb实现所需的功能。这个 SHOW TOPICS 命令是系统命令,不是sql语句。因此查询的输出不能通过管道传输到流中。
ksqldb允许您处理kafka集群中主题内的数据。它(还)不允许您处理kafka集群的元数据,例如主题列表或消费者组等。
可能值得在github上提出一个功能请求:https://github.com/confluentinc/ksql/issues/new/choose

相关问题