ksqlDB CLI镜像

镜像概述

ksqlDB CLI镜像是ksqlDB的命令行界面工具，用于与ksqlDB服务交互，执行SQL语句以管理和操作流处理应用。ksqlDB是专为流处理应用构建的事件流数据库，基于Apache Kafka，具备分布式、可扩展、可靠和实时的特性，通过类SQL语法将实时流处理能力与关系数据库的易用性结合，支持创建流、表、物化视图，执行推送/拉取查询等核心操作。

核心功能

• Streams和Tables：通过SQL语法在Apache Kafka主题数据上定义带 schema 的流（Streams）和表（Tables），实现数据关系建模。
• 物化视图（Materialized Views）：使用SQL定义基于流的实时、增量更新的物化视图，高效存储计算结果。
• 推送查询（Push Queries）：持续查询，将增量结果实时推送到客户端，适用于实时数据处理场景。
• 拉取查询（Pull Queries）：按需查询物化视图，类似传统数据库的查询方式，支持实时数据检索。
• Connect集成：完全在ksqlDB内集成Kafka Connect，连接任意数据源或数据 sink，简化数据集成流程。

使用场景

• 开发与测试：在开发或测试环境中，通过CLI与ksqlDB服务交互，快速编写和调试SQL语句，验证流处理逻辑。
• 流处理任务管理：执行SQL脚本批量创建/删除流、表、物化视图，管理流处理任务的生命周期。
• 监控与调试：通过执行查询语句监控ksqlDB应用状态，调试数据处理异常，查看实时数据流。

使用方法

基本使用

通过docker run命令启动ksqlDB CLI容器，连接到ksqlDB服务：

bash
docker run --rm confluentinc/cp-ksqldb-cli:latest ksql http://<ksqldb-server-host>:8088

• --rm：容器退出后自动删除。
• confluentinc/cp-ksqldb-cli:latest：ksqlDB CLI镜像（具体版本可替换为指定版本号）。
• ksql http://<ksqldb-server-host>:8088：连接到指定地址的ksqlDB服务（默认端口8088）。

交互模式

执行上述命令后，CLI进入交互模式，可直接输入SQL语句操作ksqlDB：

sql
-- 创建流
CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) 
  WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='JSON');

-- 执行推送查询
SELECT userid, pageid FROM pageviews EMIT CHANGES;

-- 执行拉取查询
SELECT COUNT(*) FROM pageviews WHERE pageid = 'home' EMIT CHANGES LIMIT 1;

执行SQL脚本

通过-f参数执行本地SQL脚本文件：

bash
docker run --rm -v $(pwd):/scripts confluentinc/cp-ksqldb-cli:latest ksql http://<ksqldb-server-host>:8088 -f /scripts/stream_scripts.sql

• -v $(pwd):/scripts：将本地当前目录挂载到容器内/scripts目录。
• -f /scripts/stream_scripts.sql：指定要执行的SQL脚本路径。

许可证

使用此镜像受其中包含软件的许可条款约束。详情请参考Confluent Docker镜像文档参考。用于扩展和构建自定义Docker镜像的软件在Apache 2.0许可下可用。