2

我正在尝试控制在 KCL 的 processRecords 方法中获取的记录数，这是我的 KCL 配置

new KinesisClientLibConfiguration(
        config.getApplicationName(), config.getStreamName(), awsCredentialsProvider, workerId)
        .withInitialPositionInStream(InitialPositionInStream.LATEST)
        .withRegionName(config.getRegion())
        .withMaxRecords(config.getMaxRecords())

我的 config.getMaxRecords() 设置为 500，但我仍然在 processRecords 方法中获得约 1000-1500 条记录，我希望严格的上限为 500，因为我的下游进程无法处理更多。

4

0 回答 0