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