require one record at least when ShardIteratorType is AT_TIMESTAMP

[kikumoto]

ShardIteratorType が AT_TIMESTAMP の場合、最初に得られた ShardIterator でも GetRecords で戻ってくる Records が要素数 0 の場合があります。
AWSのサポートに確認したら、そういう仕様という返答でした。レコードが取得できるまで、繰り返すようにと。
このため、end パラメータも指定していると、isTimeOver(time.Now()) の判定で１件もレコードを取得することなしに、kinesis-tailf が終了してしまいます。
これを回避するためのPRとなります。

ただし、PRの初期コミットの実装においては、

• endの指定がなく start のみ
• 該当ストリームがさほどアクティブでない
• start が最後に登録されたレコード以降の日時

の場合に、新規にレコードが追加されるまでインターバルなしにGetRecordsを繰り返してしまいます。

[fujiwara]

ありがとうございます。
この状態だと、start, end が指定されていてかつその間に本当に1件もレコードがない場合にも無限にリトライしてしまいそうです。少し対応を考えますね。

[kikumoto]

確かに。そうですね。
お願いします。。。

[fujiwara]

@kikumoto 大変放置してしまってすみません…v0.3.2で別の方法で対応してみました。
https://github.com/fujiwara/kinesis-tailf/releases/tag/v0.3.2

[kikumoto]

ありがとうございます。
動作、みてみますねー。（ちょっと時間ください...）

大変放置してしまってすみません…

とんでもない。対応版を実装いただけでも感謝です。

[kikumoto]

動作みました。
start をかなりアバウトに指定しても、待てばデータを得られるようになったので、実装いただいた動作で十分です。
ありがとうございました。