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)

Я неправильно понимаю, что делают эти параметры?

0 ответов

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