Bir şirket, Amazon EC2 üzerinde çalışan bir uygulamadan büyük hacimli akış verilerini almaktadır. Uygulama, varsayılan ayarlarla yapılandırılmış Amazon Kinesis Data Streams'e veri gönderir. Uygulama, iki günde bir verileri tüketir ve BI işleme için bir Amazon S3 bucket'ına yazar. Şirket, S3'ün Kinesis Data Streams'e gönderilen tüm verileri almadığını fark eder. Bir çözümler mimarı bunu çözmek için ne yapmalıdır?

Uygulama, Kinesis Data Streams'e veri gönderiyor ancak S3'e tüm veriler ulaşmıyorsa, bu durum genellikle Kinesis'in varsayılan veri saklama süresi olan 24 saatten kaynaklanır. Uygulama verileri iki günde bir tükettiği için, ilk 24 saatten sonraki veriler tüketilmeden önce Kinesis'ten silinir. Çözüm mimarı, Kinesis Data Streams'in veri saklama süresini uygulamanın tüketim aralığına uygun olacak şekilde (örneğin, 48 saat veya daha fazla) artırmalıdır. KPL kullanmak veri üretimini optimize etse de veri kaybını engellemez. Shard sayısını artırmak, Kinesis'in kapasitesini artırır ancak veri saklama süresi sorununu çözmez. S3 Versioning, S3'e ulaşan verilerin sürümlerini korur, ancak Kinesis'ten S3'e ulaşmayan verileri kurtarmaz.