camel gcp pubsub attributes maxMessagesPerPoll создает проблемы, когда у меня число больше 1

Question

My Apache Приложение Camel принимает сообщения от производителя-sub подписки gcp pubsub, а затем после обработки и перевода сообщений помещает их в тему pubsub gcp1

Вот мой код подписки Camel

from ("google-pubsub: // mygcpcloudpubsub-270721: продюсер-sub? ConcurrentConsumers = 10 & maxMessagesPerPoll = 1") .process (новый процессор переводов (маршрут)). to ("google-pubsub: // mygcpcloudpubsub-270721: topic1") .end

Все выглядит хорошо, пока maxMessagesPerPoll = 1

Момент, я говорю 100, т.е. maxMessagesPerPoll = 100,

Например, если мой тестовый код перекачивает 1000 сообщений в Producer-topi c (продюсер-sub является подписчиком), теперь мое приложение публикует 1300 сообщений в topic1. Иногда 1430. ..et c. Мой маршрут верблюда испорчен!

Похоже, есть ошибка в параметре maxMessagesPerPoll компонента gcp pubsub для apache camel.

Пожалуйста, дайте мне знать, если Я ничего не упускаю.

Answer 1

Я обнаружил проблему. Для большого количества сообщений мой крайний срок подтверждения в 10 секунд был слишком мал. Следовательно, сообщения были повторно доставлены pubsub. Я увеличиваю срок до 10 минут .... теперь нет повторяющихся сообщений! !!

Еще раз спасибо