kinesis issues

Receive the same message twice

Hi everyone, I'm just finished my project and started to running it, but I'm receiving the same message twice. Here is my code: ``` function connectToOrderStream(){ var kinesisSource = kinesis.stream({...

mfazevedo

Right way to close a Kinesis stream

6

Hi, What is the right way to close/terminate a Kinesis stream? I would like a Kinesis stream to stop consuming any resources. I'm using only the readable part of the...

itamarwe

Add Limit as parameter to GetRecords

1

The default limit is set to 25, which is the Kinesis API default. The limit can be overridden with `options.limit = newLimit`.

gudmundur

Adds backoffTime option to throttle on getRecords

3

By getting records immediately after a successful `GetRecords` call there is the potentially starving other Kinesis consumers on the stream. This change adds an optional `backoffTime` (ms) option that sleeps...

gudmundur

Support for KPL aggregated records

Any plans to support [KPL aggregated records](https://github.com/awslabs/amazon-kinesis-producer/blob/master/aggregation-format.md)?

samcday

no putRecords for batch writting

2

Hi, I found it is only putRecord but no putRecords for batch operation. I have just do the load test today, when the write reach 200/sec, response will be 400...

shiroh