kinesis-storm-spout:风暴的Kinesis壶嘴

时间:2021-03-27 07:36:56
【文件属性】:
文件名称:kinesis-storm-spout:风暴的Kinesis壶嘴
文件大小:77KB
文件格式:ZIP
更新时间:2021-03-27 07:36:56
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)

网友评论