Я вызываю spark-submit, передавая maxRate, у меня есть один приемник kinesis и пакеты из 1 с. spark-submit --conf spark.streaming.receiver.maxRate=10 .... однако одна партия может значительно превышать установленную максимальную скорость. то...

Я использую aws-sdk (версия 2.1.8) для получения записей из Kinesis. Это внутри лямбда-функции узла. Попытка использовать ShardIteratorType: AT_TIMESTAMP. Я указываю метку времени в объекте params const AWS = require("aws-sdk"); const kinesis =...