2017-02-21 7 views
0

私はputRecords経由でawes kinesisにデータを送信します。すべてのデータが正常に送信されます。 しかし、一部のレコードは消費者側で2回受信されます。私は送信されたデータをチェックしてデータを受信しましたが、それは同じです。 私はPutRecordsがkinesisサーバーからの応答を受け取っていないときにデータを再送信すると考えています(ひどいネットワークステーションのために応答が失われました)。しかし、データはキネシスサーバーによって受信されます。 したがって、消費者側で同じレコードを2回取得します。PutRecordsはネットワークがひどいときにデータを再送信しますか?

私の前提は正しいですか?

答えて

0

使用しているSDKのバージョンは何ですか? SDKはタイムアウト時に再試行しません。だから私はそれが理由だとは思わない。

重複の理由が何であれ、重複を扱うことについての良い投稿がありますhere

+0

ご返信ありがとうございます。私は返信フォームのサポートチームを持って、記録はキネシスサーバー側に格納される可能性がありますが、不良ネットワークのためにsdkがエラーを返します。返信されたエラーのため、私のアプリは再びレコードを送信します。各レコードにプライマリキーまたはユニークインデックスを追加する必要があります。だから私は受け取ったいくつかのレコードを削除することができます。 http://docs.aws.amazon.com/streams/latest/dev/kinesis-record-processor-duplicates.html#kinesis-record-processor-duplicates-producerありがとうございました!良い一日を! –

関連する問題