Как получить thread_id текущих изменений в БД, выполненных через сервис весенней загрузки.
Я посмотрел в DataSource, но в этом я не могу найти что-либо связанное с thread_id.
Я следую за одной статьей medium.com .
Здесь мы получаем журналы изменений БД с помощью Maxwell. Максвелл генерирует журналы изменений с помощью DB thread_id в Kafka.
Когда кто-то нажимает на любую конечную точку REST службы, эта служба использует свою логику для изменения одной вставки некоторых записей в БД (это изменение будет иметь отношение к MySQL thread_id
), Максвелл отправляет сообщение в Kafka, касающееся изменения, выполненного в БД тот же сервис должен сделать одну запись в БД, используя MySQL Blackhole Engine, который отображает БД thread_id
и Сервис request_id
. Как мы можем запросить MySQL, чтобы получить thread_id
.