0

我通过 PutRecords 将数据发送到 aws kinesis。并且所有数据都发送成功。但是有些记录在消费者端被接收两次。我检查了发送的数据和接收的数据,它们是相同的。我认为当 PutRecords 没有收到来自 kinesis 服务器的响应(由于糟糕的网络站点导致响应丢失)时,它会重新发送数据。但是数据是由 kinesis 服务器接收的。因此,我在消费者方面获得了两次相同的记录。

我的假设正确吗?

4

1 回答 1

0

您使用的是什么版本的 SDK?SDK 不会在超时时重试。所以我不认为这是原因。

不管重复的原因是什么,这里有一篇关于处理重复的好帖子。

于 2017-03-01T20:09:15.457 回答