我必须在生产服务器上部署ksql,所以我将交互模式改为无头模式。创建了一个sql脚本以在容器启动时加载所有流。现在我想看看流数据。有多少种方法可以看到这些实时流,比如我们可以将ksql服务器连接到控制中心并实现这一点。但我不想让依赖性像我们需要购买企业版的合流。请给出您的建议或意见。
fjaof16o1#
ksql(或者ksqldb在技术上是正确的)是构建在apachekafka之上的流分析层。虽然这是一种口头表达,对不同的人可能意味着不同的事情——在您的特殊情况下,这意味着如果您需要查看数据流,您可以简单地监视由sql脚本的流/表创建的kafka主题。在ksqldb中,由连续查询支持的每个流和/或表都将其结果刷新到包含前缀的生成主题中(这由 ksql.output.topic.name.prefix 配置参数)和流/表的名称。只需使用任何cli工具(如kafka console consumer、kafkacat等)即可连接到kafka集群并打印主题内容。
ksql.output.topic.name.prefix
1条答案
按热度按时间fjaof16o1#
ksql(或者ksqldb在技术上是正确的)是构建在apachekafka之上的流分析层。虽然这是一种口头表达,对不同的人可能意味着不同的事情——在您的特殊情况下,这意味着如果您需要查看数据流,您可以简单地监视由sql脚本的流/表创建的kafka主题。
在ksqldb中,由连续查询支持的每个流和/或表都将其结果刷新到包含前缀的生成主题中(这由
ksql.output.topic.name.prefix
配置参数)和流/表的名称。只需使用任何cli工具(如kafka console consumer、kafkacat等)即可连接到kafka集群并打印主题内容。