- 如果您觉得本站非常有看点，那么赶紧使用Ctrl+D 收藏吧
我正在使用KCL(v2)将Kafka使用者转换为AWS Kinesis使用者。在Kafka中，偏移量用于帮助消费者跟踪其最近消费的消息。如果我的Kafka应用程序死了，它将使用偏移量重新启动时从中断处开始消耗。
但是，这在Kinesis中并不相同。我可以设置kinesisClientLibConfiguration.withInitialPositionIn……继续阅读 »
无法打开与Monitoring.us-east-1.amazonaws.com:443的连接：连接到AWS kinesis时证书验证失败
public static KinesisProducer getKinesisProducer() {
KinesisProducerConfiguration config = new KinesisProd……继续阅读 »
我刚开始使用其API可用的Kinesis here
我用它来将 100条记录推送到 kinesis
for (int j = 0; j < 100; j++) {
PutRecordRequest putRecordRequest = new PutRecordRequest();
putRecordRequest.s……继续阅读 »
到目前为止，我已经按照Flink的kinesis连接器记录的说明使用本地Kinesis。
Using Non-AWS Kinesis Endpoints for Testing
Properties producerConfig = new Properties();
producerConfig.put(AWSConfigConstants.AWS_RE……继续阅读 »
我们正在研究使用Spring Boot开发的Micro服务，该服务使用Kinesis流中的数据对其进行处理，然后将其存储在DB中。我们有良好的JUnit Mockito测试覆盖率。现在我们需要对此进行集成测试。您能否建议一个好的框架或框架集，以用于端到端地测试整个应用程序。到目前为止，我们已经检查了柑橘和弹簧整合法，但是没有运气
解决方案如下：
通常……继续阅读 »
我正在尝试使用DynamoDB流和AWS提供的Java DynamoDB流Kinesis适配器捕获DynamoDB表更改。我正在Scala应用程序中使用AWS Java SDK。
我首先关注AWS guide并阅读了AWS发布的code example。但是，在使Amazon自己的已发布代码在我的环境中运行时，我遇到了问题。我的问题在于KinesisClie……继续阅读 »
实际情况
我想将Apache Flink与Kinesis Analytics结合使用。就像我没有Java和Maven的经验一样，我将尝试总结我遵循的步骤和结果。
使用IntelliJ IDEA作为IDE
毫无问题地测试此example
按照其instruction更改为AWS。问题开始于以下步骤:创建并编译Apache Flink流Java代码
问题
……继续阅读 »
要求:在插入/更新到特定表时，创建一个数据流并将其推入 flex 搜索。
思想 AWS RDS(MariaDb)—–插入/更新以说出用户表—> AWS Kinesis流-使用AWS Lambda-> AWS ES
问题如何在插入/更新到特定表时创建运动流？我可以通过AWS Lambda吗？
解决方案如下……继续阅读 »
