AWS Kinesis Producer Library 可以配置为在发送到 AWS Kinesis Stream 之前聚合记录。例如我们可以设置:
final KinesisProducerConfiguration config = new KinesisProducerConfiguration();
config.setRecordMaxBufferedTime(1000);
config.setAggregationMaxCount(100);
config.setRegion("eu-west-1");
return config;
这个缓冲区是仅在内存中还是保存在文件系统中?大多数情况下,我想知道,当生产者节点重新启动时,当前缓冲区是否丢失。