如何启用Localstack Kinesis Data Streams捕获内存DynamoDB变更

• 本地开发目标：通过Kinesis Data Streams消费处理DynamoDB变更事件
• 初始实现方案：使用Localstack同时部署本地DynamoDB与Kinesis服务，功能运行符合预期，但存在偶发的Localstack DynamoDB运行卡顿问题，该问题为Localstack社区已知问题
• 优化调整方向：为解决性能卡顿问题，切换为InMemory模式的官方DynamoDB Local版本，保留Localstack上运行的Kinesis Data Stream服务
• 触发异常：内存版DynamoDB Local无法与Localstack部署的Kinesis服务正常通信，持续抛出resource not found异常

方案1：显式指定DynamoDB Local的Kinesis端点配置（推荐，适配2.0及以上版本DynamoDB Local） #

该异常90%以上的诱因是DynamoDB Local默认会请求公网AWS官方Kinesis端点，而非本地Localstack服务，同时区域、ARN配置不匹配也会触发同类报错，按以下步骤配置即可解决：

1. 启动DynamoDB Local时，除-inMemory参数外，额外添加Kinesis端点、区域指定参数，强制将Kinesis请求转发到本地Localstack服务：

   java -Djava.library.path=./DynamoDBLocal_lib \
     -jar DynamoDBLocal.jar \
     -inMemory \
     -kinesisEndpoint http://127.0.0.1:4566 \
     -kinesisRegion us-east-1
   

   注意：此处指定的区域必须和你在Localstack上创建Kinesis流时使用的区域完全一致，DynamoDB Local会通过区域+流名称匹配资源，区域不匹配会直接返回资源不存在的报错；Localstack默认跳过AK/SK签名校验，不需要额外配置鉴权参数。

2. 调用DynamoDB API开启Kinesis流投递时，填写的Kinesis流ARN必须和Localstack的规则对齐，默认格式为arn:aws:kinesis:us-east-1:000000000000:stream/<你的流名称>，不要使用自定义账号ID、分区后缀。

方案2：本地请求转发适配（适配1.x版本DynamoDB Local） #

如果使用的旧版DynamoDB Local不支持-kinesisEndpoint启动参数，可以通过本地流量转发的方式实现请求路由：

1. 修改本地hosts文件，添加映射规则将kinesis.<你使用的区域>.amazonaws.com指向127.0.0.1
2. 用socat、nginx等反向代理工具监听本地443端口，将收到的Kinesis服务请求全部转发到Localstack的4566端口
3. 启动DynamoDB Local时添加关闭SSL校验、指定区域的参数：

   java -Djava.library.path=./DynamoDBLocal_lib \
     -jar DynamoDBLocal.jar \
     -inMemory \
     -kinesisRegion us-east-1 \
     -disableSslCertCheck
   

方案3：轻量服务替代（低调试成本场景） #

如果不想做复杂的网络配置，可以直接替换Localstack的Kinesis服务为Kinesalite这类轻量内存版Kinesis实现，和DynamoDB Local部署在同一本地网络中，按方案1的逻辑指定端点即可，整体资源占用远低于全量Localstack，不会出现之前的DynamoDB卡顿问题。

内容的提问来源于stack exchange，提问作者asn3416