From 34bbdb578746a18408c35e5e37c2650e1a57d0a1 Mon Sep 17 00:00:00 2001 From: phb136136 Date: Thu, 28 Sep 2023 22:28:13 +1000 Subject: [PATCH] added in hot fix --- internal/impl/aws/input_kinesis.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/internal/impl/aws/input_kinesis.go b/internal/impl/aws/input_kinesis.go index 2da319c01c..a52d6adff7 100644 --- a/internal/impl/aws/input_kinesis.go +++ b/internal/impl/aws/input_kinesis.go @@ -559,6 +559,9 @@ func (k *kinesisReader) runBalancedShards() { for _, streamID := range k.balancedStreams { shardsRes, err := k.svc.ListShardsWithContext(k.ctx, &kinesis.ListShardsInput{ StreamName: aws.String(streamID), + ShardFilter: &kinesis.ShardFilter{ + Type: aws.String("AT_LATEST"), + }, }) var clientClaims map[string][]awsKinesisClientClaim