我是ksql的新手。我想使用ksql查询将kafka集群中的所有主题名称存储到另一个主题。 SHOW TOPICS; 来自ksql的cli提供了主题列表。我想通过创建一个流将所有这些主题信息存储在另一个主题中。我将轮询这个新主题(使用使用者),每当在集群中创建新主题时,我的使用者将收到一条消息。我需要一个ksql查询来完成这个任务。提前谢谢。
SHOW TOPICS;
klr1opcd1#
您目前无法使用ksqldb实现所需的功能。这个 SHOW TOPICS 命令是系统命令,不是sql语句。因此查询的输出不能通过管道传输到流中。ksqldb允许您处理kafka集群中主题内的数据。它(还)不允许您处理kafka集群的元数据,例如主题列表或消费者组等。可能值得在github上提出一个功能请求:https://github.com/confluentinc/ksql/issues/new/choose
SHOW TOPICS
1条答案
按热度按时间klr1opcd1#
您目前无法使用ksqldb实现所需的功能。这个
SHOW TOPICS
命令是系统命令,不是sql语句。因此查询的输出不能通过管道传输到流中。ksqldb允许您处理kafka集群中主题内的数据。它(还)不允许您处理kafka集群的元数据,例如主题列表或消费者组等。
可能值得在github上提出一个功能请求:https://github.com/confluentinc/ksql/issues/new/choose