0

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;

这个缓冲区是仅在内存中还是保存在文件系统中?大多数情况下,我想知道,当生产者节点重新启动时,当前缓冲区是否丢失。

4

0 回答 0