added in hot fix

Canva · Sep 28, 2023 · 34bbdb5 · 34bbdb5
1 parent c60fdb4
commit 34bbdb5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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