запущенный коннектор, который читал из WAL постгреса.
Но периодически оно отрубалось и нормально почитать это всё не удалось. В итоге у меня есть топики отдельно по таблицам.
Я могу их как-нибудь заново прочитать?
С учётом того, что изначально они через стримы собирались в один топик, который содержит в себе джойн всех таблиц
должен быть топик типа connect-offsets. там хранятся значения первичных ключей, которые были вычитаны из таблиц. останавливаешь коннектор (и таск обязательно), пролюсишь в этот топик руками запись с инкрементом = 0, перезапускаешь коннектор
Обсуждают сегодня