Итак, я новичок в AWS Kinesis, и у меня есть базовый производитель, который отлично работает с моим профилем по умолчанию, в котором хранятся мои данные пользователя IAM.
Я вижу, что производитель отправляет сообщения в шард одного потока. Это все хорошо.
Я знаю, что есть потребитель API Kinesis Data Stream, который также использует AmazonKinesisClient. Но я прочитал, что предпочтительным подходом было использование библиотеки KCL
https://github.com/awslabs/amazon-kinesis-client-net
Итак, я скачал образец потребителя по ссылке выше и сделал следующее
- Убедитесь, что у меня есть переменные среды для AWS_ACCESS_KEY_ID и AWS_SECRET_ACCESS_KEY для приложения SampleConsumer
- Убедитесь, что у меня установлена Java
- Отредактировал аргументы командной строки SampleConsumer для включения "--properties kcl.properties --execute"
- Убедитесь, что файл kcl.properties имеет правильное имя streamName / executetableName / regionName (которое я изменил в соответствии с моим регионом для производителя / моей учетной записи AWS, поэтому eu-west-2)
Затем, когда я запускаю SampleConsumer сверху с помощью SampleProducer, все, что я вижу для SampleConsumer, это пустое консольное приложение.
Производитель на 100% в порядке.
У кого-нибудь есть идеи?