Запустить Kinesis только тогда, когда количество записей превышает x? - PullRequest
Новая
       10

Запустить Kinesis только тогда, когда количество записей превышает x?

0 голосов
/ 02 декабря 2018

Есть ли способ создать пользователя Kinesis с ограничениями буфера?Как и здесь : 

#Flush when buffer exceeds 100000 Amazon Kinesis records, 64 MB size limit or when time since last buffer exceeds 1 hour
bufferByteSizeLimit = 67108864 
bufferRecordCountLimit = 100000
bufferMillisecondsLimit = 3600000

По сути, я хочу начать IRecordProcessor только при наличии значительного объема данных.Я не могу использовать вышеуказанный код соединителя, потому что мне нужна последняя версия amazon-kinesis-client.

...