У меня есть коннектор снежной трубы Kafka. Разъем находился в неисправном состоянии много дней. когда я перезапустил разъем, лаг начало уменьшаться. есть 5 разделов, но 4 раздела работают нормально, задержка равна 0, но 1 раздел имеет огромную задержку, и задержка не уменьшается.
Я подозреваю, что это потому, что срок хранения Topi c составлял 5 дней, а разъем был в отказавшее состояние на более длительный срок.
Может ли кто-нибудь мне помочь с этим, почему это происходит, и я не хочу сбрасывать смещение вручную?