动情是否保证交付？
我正在搜索动觉数据流的文档，但我找不到像
动情保证至少一次交付
从生产者方面，我预计发送的消息会传播到多个节点（类似于Kafka的ack=all）从消费者方面，我预计在消费者成功处理时会有相当于Kafka提交偏移量的东西，或者类似于Google Cloud的Pub/Sub消息确认。
是否有动觉提交信息保证？是否有动觉处理保证（如果已处理并确认已处理，则将消息标记为只读）
共有2个答案
从评论中，如果您真的想要无服务器方法，为什么不使用Lambda事件源映射来使用Kinesis消息？
- Lambda/AWS将轮询消息，对它们进行批处理，并调用Lambda函数以获取一批记录（批大小为1）
- 若Lambda函数返回成功，则将提交批，并为下一批调用函数
- 如果Lambda函数返回失败，则批处理可以失效
- 与Kafka使用者不同的是，我们需要使用另一个Kafka主题或数据库单独处理重试异常，以保持使用者向前发展，AWS Lambda也支持异步失效
对于一个简单的用例，Kinesis Lambda与Kafka Consumer一样优秀。
根据文档，KinesIs的消费者从流中读取整个数据。因此，消费者有责任提交他们的历史，并从他们离开的地方拾起。https://docs.aws.amazon.com/streams/latest/dev/building-consumers.html
-
问题内容： 参考以下链接：http : //docs.python.org/faq/library.html#what- kinds-of-global-value-mutation-are-thread- safe 我想知道以下情况： 在cPython中将保证是原子的。（x和y都是python变量） 问题答案： 让我们来看看： 它不会出现，他们是原子：x的和y的值可以被另一个线程之间改变字节码，
-
问题内容： 我真的是在这里指身份平等。 例如，以下内容将始终打印 true 吗？ 问题答案： 是的，类令牌是唯一的（对于任何给定的类加载器而言）。 即，您将始终 在相同的类加载器领域中 获得对相同物理对象的引用。但是，不同的类加载器将加载不同的类令牌，同时，当两个不同的类加载器加载相同的类定义时，会将相同的类定义视为不同。
-
问题内容： 考虑以下代码： 当第一个URL够用时会被要求输入第二个URL吗？ 我尝试了一个较小的示例，它看起来像预期的那样工作。即一个一个地处理数据，但是可以依靠这种行为吗？如果没有，在帮助之前打电话吗？ 输出： 更新 ：如果对实施很重要，请使用官方Oracle JDK8 答案 ：根据下面的评论和答案，flatmap部分是惰性的。即完全读取第一个流，并且仅在需要时才读取下一个。渴望读取一个流，但是
-
我想做的是将一个 64 位无符号整数存储为 类型，保留其间隔二进制表示形式。 例如，我想保存 2^63-1=9223372036854775807（9223372036854775807）（2^63-1 和 2^63 = 9223372036854775808 = 10000000 000000000000000000000000000000000 000000000000(2) as-92233
-
问题内容： 在下面的程序中，如果执行了此程序（例如，通过命令行），则是否可以单独确保args JVM不为null？ 问题答案： 简短的回答：是的，它的长度可能为0，但不会为null。
-
问题内容： 众所周知，JavaScript在所有现代浏览器实现中都是单线程的，但是它是在任何标准中指定的，还是仅根据传统？假设JavaScript始终是单线程的，是否完全安全？ 问题答案： 这是个好问题。我很想说“是”。我不能 通常认为JavaScript具有脚本（*）可见的单个执行线程，因此，当您输入内联脚本，事件侦听器或超时时，您将完全处于控制状态，直到从块或函数的结尾返回为止。 （*：忽略浏