Как контролировать количество записей в клиентской библиотеке Kinesis

Я пытаюсь контролировать количество записей, выбранных в методе processRecords KCL, вот моя конфигурация KCL

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

Мой config.getMaxRecords() установлен в 500, но я все еще получаю ~1000-1500 записей в методе processRecords, я хочу строгий верхний предел как 500, так как мой последующий процесс не может обработать больше, чем это.

Источник

0 ответов

Другие вопросы по тегам