KSQL server 运行 在Headless模式下如何处理流数据?

How to process stream data when KSQL server running in Headless mode?

我必须在生产服务器上部署 KSQL,因此我已将交互模式更改为无头模式。创建了 SQL 脚本以在容器启动时加载所有流。现在我想看流数据。有多少种方式可以看到这些实时流,比如我们可以将 KSQL 服务器连接到控制中心并实现这一点。但我不想像我们需要购买 Confluent 的企业版那样依赖。 请提出您的建议或意见。

KSQL(或者 ksqlDB 在技术上是正确的)是一个建立在 Apache Kafka 之上的流分析层。虽然这很啰嗦,对不同的人来说可能意味着不同的事情——在你的特定情况下,这意味着如果你需要查看数据流,你可以简单地监视由 streams/tables 的 [=19] 创建的 Kafka 主题=] 脚本.

在 ksqlDB 中,由连续查询支持的每个流 and/or table 将其结果刷新到包含前缀的生成主题中(这由 ksql.output.topic.name.prefix 配置决定参数)和 stream/table 的名称。只需使用任何CLI工具(如kafka-console-consumer、kafkacat等)连接到Kafka集群并打印主题内容即可。