Sahil Palvia

@oscarjiv91 I don't think your issue is related to this one, but to be sure I would need some additional information. Could you provide the link to the sample that...

@juanstiza Are you using the Java KCL or the Multilang?

Kinesis does emit a Stream level metrics for iterator age, called GetRecords.IteratorAgeMillis. You should be able to setup alarm on that metric. That metric can be found under the Kinesis...

Thank you for the feedback. We agree with the change you have suggested, and will prioritize it accordingly against the other customer requests we receive.

The commit message that you posted has the fix for Polling configuration for the KCL. You seem to be using EnhancedFanout out if you are seeing SubscribeToShardEvent.MillisBehindLatest metric. Can you...

Could you try running the application with KCL 2.1.1?

@awadeshmmm That is not how the KCL works. The KCL keeps the ShardConsumer around for as long as the shard is active. So the only way to shutdown a particular...

@sudharshanPLT This is just an initial speculation of your issue based on the information provided. More details would be required for a more concrete and detailed explanation. It seems like...

@sudharshanPLT `bufferByteSizeLimit`, `bufferRecordCountLimit` and `bufferMillisecondsLimit` are used to check if the buffer needs to be flushed. You can check the logic behind the `shouldFlush` method [here](https://github.com/awslabs/amazon-kinesis-connectors/blob/13e41407e617aadf248ca7e636af2f198bdfae4e/src/main/java/com/amazonaws/services/kinesis/connectors/impl/BasicMemoryBuffer.java#L108-L112). As you can see...

Kinesis ShardHour pricing mentions that the shard is charged at an hourly rate. That means as long as the shards exist the customer will be charged for it. In this...