当 KSQL 服务器以无头模式运行时如何处理流数据?



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

KSQL(或技术上正确的ksqlDB(是一个建立在Apache Kafka之上的流分析层。虽然这很拗口,并且对不同的人可能意味着不同的事情 - 在你的特殊情况下,这意味着如果你需要查看数据流,你可以简单地监视由SQL脚本的流/表创建的Kafka主题。

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

最新更新