文件名称：kinesis-storm-spout:风暴的Kinesis壶嘴
文件大小：77KB
文件格式：ZIP
更新时间：2024-04-16 01:23:36
Java
亚马逊Kinesis风暴喷口 Amazon Kinesis Storm喷口可帮助Java开发人员将与集成。 要求 或更高版本 3.0或更高版本 13.0或更高版本 当然，还有和 概述 Amazon Kinesis Storm喷口从Amazon Kinesis获取数据记录，并将其作为元组发出。 喷口将检查点状态存储在以跟踪流中的当前位置。 可以将Amazon Kinesis Storm喷口配置为重试失败的记录。 默认情况下，它将重试失败的记录3次。 如果记录失败并且已达到重试限制，则喷口将记录错误并跳过该记录。 喷口将未决记录缓存在内存中，因此它可以重新发送失败的记录，而不必从Amazon Kinesis重新获取记录。 喷口将检查点设置为已确认（或尝试失败的重试次数）的最高序列号。 要使用喷嘴，您需要将其添加到Storm拓扑中。 KinesisSpout ：使用您的AWS凭证和Ki
【文件预览】：
kinesis-storm-spout-master
----.gitignore(34B)
----META-INF()
--------MANIFEST.MF(1KB)
----build.properties(213B)
----src()
--------main()
--------test()
----NOTICE.txt(105B)
----LICENSE.txt(5KB)
----pom.xml(4KB)
----README.md(4KB)