instructure/kinesalite

kinesalite Docker镜像

镜像概述

kinesalite Docker镜像是Kinesalite的容器化包装，而Kinesalite是AWS Kinesis的本地开源实现。该镜像提供了一个轻量级的本地Kinesis服务环境，无需依赖AWS云服务，便于开发人员在本地进行Kinesis相关应用的开发、测试和调试。

核心功能与特性

• 本地模拟AWS Kinesis：完整模拟AWS Kinesis的核心功能，包括流创建、数据写入、数据读取等操作
• 轻量级部署：容器化设计，启动快速，资源占用低，适合开发环境快速搭建
• 端口可访问：默认监听4567端口，支持端口映射，方便本地应用连接
• 无需AWS凭证：本地运行时无需配置真实AWS访问密钥，降低开发环境复杂度

使用场景与适用范围

• 开发环境中测试依赖Kinesis数据流的应用程序
• 本地调试Kinesis生产者、消费者逻辑
• 教学或演示场景中模拟Kinesis服务工作流程
• 离线或低网络环境下验证Kinesis相关功能

使用方法与配置说明

基本部署命令

通过docker run命令启动容器，映射4567端口以提供外部访问：

bash
docker run -d --name mykinesis -p 4567:4567 instructure/kinesalite

参数说明：

• -d：后台运行容器
• --name mykinesis：指定容器名称为mykinesis（可自定义）
• -p 4567:4567：将容器内4567端口映射到主机4567端口，允许主机及外部访问Kinesis服务

连接与使用示例

使用AWS CLI工具连接本地Kinesalite服务（需提前安装AWS CLI）：

创建Kinesis流

bash
AWS_ACCESS_KEY_ID=x AWS_SECRET_ACCESS_KEY=x aws --endpoint-url http://localhost:4567/ kinesis create-stream --stream-name=mystream --shard-count=1

参数说明：

• AWS_ACCESS_KEY_ID=x 和 AWS_SECRET_ACCESS_KEY=x：本地服务无需真实AWS凭证，可使用任意字符串
• --endpoint-url http://localhost:4567/：指定Kinesalite服务地址（若容器运行在远程主机，需替换localhost为实际主机IP）
• create-stream：创建Kinesis流的示例命令，--stream-name指定流名称，--shard-count指定分片数量

验证流创建结果

bash
AWS_ACCESS_KEY_ID=x AWS_SECRET_ACCESS_KEY=x aws --endpoint-url http://localhost:4567/ kinesis list-streams

执行后将返回已创建的流列表，确认服务正常运行。

常用操作扩展

除创建流外，还可执行其他Kinesis操作，例如：

• 列出所有流：aws --endpoint-url http://localhost:4567/ kinesis list-streams
• 向流写入数据：aws --endpoint-url http://localhost:4567/ kinesis put-record --stream-name mystream --data "test-data" --partition-key "partition-1"
• 读取流数据：aws --endpoint-url http://localhost:4567/ kinesis get-shard-iterator --stream-name mystream --shard-id shardId-000000000000 --shard-iterator-type TRIM_HORIZON（获取迭代器后，使用get-records读取数据）