Pertanyaan tentang topik tersebut 'amazon-kinesis'

Spark Streaming + Kinesis : Penerima MaxRate dilanggar
Saya memanggil spark-submit dengan meneruskan maxRate, saya memiliki satu penerima kinesis, dan kumpulan 1 detik spark-submit --conf spark.streaming.receiver.maxRate=10 .... namun satu batch bisa jauh melebihi maxRate yang ditetapkan. yaitu:...
479 dilihat

AWS javascript SDK Kinesis getShardIterator Error: UnexpectedParameter: Kunci 'Timestamp' yang tidak terduga ditemukan di params
Saya menggunakan aws-sdk(versi 2.1.8) untuk mengeluarkan catatan dari Kinesis. Ini ada dalam fungsi simpul Lambda. Mencoba menggunakan ShardIteratorType: AT_TIMESTAMP. Saya menyediakan Stempel Waktu di objek params const AWS =...
360 dilihat