Camel Kinesis игнорирует параметр maxResultsPerRequest
Camel/Kinesis, похоже, игнорирует maxResultsPerRequest и жадные параметры, которые я установил в uri.
<camelContext xmlns="http://camel.apache.org/schema/blueprint" >
<route>
<from uri="aws-kinesis://my-stream?maxResultsPerRequest=25&greedy=true"/>
<to uri="stream:out"/>
</route>
</camelContext>
Поскольку в осколке есть куча сообщений, ожидающих использования, я ожидал, что он прочитает первые 25 сообщений сразу, увидит, что их больше, а затем немедленно проведет опрос, чтобы получить следующие 25.
Но вместо этого он по-прежнему читает их по одному, со скоростью, которая выглядит как одна каждые полсекунды (что совпадает с задержкой опроса по умолчанию 500 мс, указанной в документации). Настройка параметра задержки на меньшее значение также, похоже, ничего не дает.
Таким образом, похоже, что он игнорирует как maxPerRequest, так и жадный флаг.
maxResultsPerRequest: максимальное количество записей, которые будут извлечены в каждом опросе (int, по умолчанию 1)
жадный: если жадный включен, то ScheduledPollConsumer немедленно запустится снова, если предыдущий прогон опросил 1 или более сообщений. (логическое, по умолчанию false)
delay: миллисекунды до следующего опроса (длинный, по умолчанию 500)
Я неправильно понимаю, что делают эти параметры?