首页 > 解决方案 > AWS KCL C# 不处理记录

问题描述

所以我是 AWS Kinesis 的新手,我有一个基础生产者可以很好地使用我的默认配置文件,该配置文件在商店中有我的 IAM 用户详细信息。

我可以看到生产者将消息发送到单个流分片。这都很好。

我知道有一个 Kinesis Data Stream API 使用者也使用 AmazonKinesisClient。但我读到的首选方法是使用 KCL 库

https://github.com/awslabs/amazon-kinesis-client-net

所以我从上面的链接下载了示例消费者,并做了以下

  1. 确保我有用于 SampleConsumer 应用程序的 AWS_ACCESS_KEY_ID 和 AWS_SECRET_ACCESS_KEY 的环境变量
  2. 确保我安装了 Java
  3. 编辑 SampleConsumer 命令行参数以包含“--properties kcl.properties --execute”
  4. 确保 kcl.properties 文件具有正确的 streamName/executableName/regionName(我将其更改为与生产者/我的 AWS 账户的区域匹配,所以 eu-west-2)

然后,当我使用 SampleProducer 从上面运行 SampleConsumer 时,我看到的 SampleConsumer 只是一个空白控制台应用程序。

制作人100%没问题。

有人有想法么?

标签: amazon-web-servicesamazon-kcl

解决方案


推荐阅读