Библиотека AWS Kinesis Producer может быть настроена на агрегирование записей перед отправкой в AWS Kinesis Stream.Например, мы можем установить:
final KinesisProducerConfiguration config = new KinesisProducerConfiguration();
config.setRecordMaxBufferedTime(1000);
config.setAggregationMaxCount(100);
config.setRegion("eu-west-1");
return config;
Этот буфер только в памяти или он сохранен в файловой системе?В основном я хотел бы знать, теряется ли текущий буфер при перезапуске узла-производителя.