Получение "текущего пакета (...) позади пакета состояния" при использовании 3 топологий - PullRequest
0 голосов
/ 21 октября 2019

У меня есть три топологии, слушающие одну и ту же тему Кафки и записывающие данные в разные таблицы HBase. Большую часть времени один из них работает, а с двумя другими я получаю, что «текущая партия (430) отстает от партии штата». Это была одна большая топология в начале, которая работала нормально, но она стала слишком большой для развертывания. Эта проблема началась после разделения на три.

Я попытался изменить "currtx" в Zookeeper на большее число, но это решает проблему только для одной топологии. Работающий onw начинает получать ту же ошибку. У меня сложилось впечатление, что в топологиях используется одно и то же значение счетчика для обслуживания состояний, что приводит к гонке данных. Испытывал ли кто-нибудь нечто подобное?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...