Camel Kinesis игнорирует параметр maxResultsPerRequest - PullRequest
Новая
       6

Camel Kinesis игнорирует параметр maxResultsPerRequest

1 голос
/ 27 февраля 2020

Верблюд / Кинезис, кажется, игнорирует 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)

задержка: миллисекунды до следующего опроса (long, по умолчанию 500)

Не понимаю ли я, что эти параметры делают?

...