amazon-web-services - AWS KCL C# 不处理记录
问题描述
所以我是 AWS Kinesis 的新手,我有一个基础生产者可以很好地使用我的默认配置文件,该配置文件在商店中有我的 IAM 用户详细信息。
我可以看到生产者将消息发送到单个流分片。这都很好。
我知道有一个 Kinesis Data Stream API 使用者也使用 AmazonKinesisClient。但我读到的首选方法是使用 KCL 库
https://github.com/awslabs/amazon-kinesis-client-net
所以我从上面的链接下载了示例消费者,并做了以下
- 确保我有用于 SampleConsumer 应用程序的 AWS_ACCESS_KEY_ID 和 AWS_SECRET_ACCESS_KEY 的环境变量
- 确保我安装了 Java
- 编辑 SampleConsumer 命令行参数以包含“--properties kcl.properties --execute”
- 确保 kcl.properties 文件具有正确的 streamName/executableName/regionName(我将其更改为与生产者/我的 AWS 账户的区域匹配,所以 eu-west-2)
然后,当我使用 SampleProducer 从上面运行 SampleConsumer 时,我看到的 SampleConsumer 只是一个空白控制台应用程序。
制作人100%没问题。
有人有想法么?
解决方案
推荐阅读
- javascript - 如何清除 Nx 缓存
- laravel - Laravel Backpack CRUDController 返回 redirect() 或跳过中间件运行 redirect()
- php - WooCommerce:排序问题:选择的 orderby 值覆盖过滤器值
- google-sheets-formula - 在 Google 表格中查询行和列的总计
- python - 如何将烧瓶中的 reqParser 转换为 python 中的 faspapi?
- java - 一个用于一元和双向流的 grpc 服务器,带有 netty
- node.js - 如何在快速验证器中验证对象数组
- asynchronous - 如何限制 async_trait 函数的返回值来实现同步?
- .htaccess - 重写 url .htaccess GET-Parameter 用于目录路由
- c# - 是否有 MQTTnet 客户端方法的同步版本?