Storm Bolt принимает кортежи, но Spout выдает их с большой задержкой

У меня довольно простая структура топологии. Носик -> Болт и все. Но время от времени я получаю такую ​​картину: пользовательский интерфейс Storm . И понятия не имею, почему это может произойти. Bolt обрабатывает все кортежи, но spout не все. У меня есть 3 исполнителя на болт, 3 на носик и 3 перегородки Kafka. Я добавил эту конфигурацию, как в ответе здесь (Storm Bolts срабатывает, но носик не работает), но это не помогло, и, в отличие от этого примера, у меня нет кортежей, которые не были активированы каким-либо болтом в моей структуре:TOPOLOGY_MAX_SPOUT_PENDING = 1000.

Может быть, есть какие-то другие важные конфигурации носика, которые могут помочь решить эту проблему, или показатели, на которые следует обратить внимание? Версия Storm - 2.3.0.

0 ответов

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