Maxwell xid в json, записанном в очередь массажа

Я вижу в json ниже, что мы получаем xid во всех jasons, написанных для kafka.

{"database":"TEST","table":"MAXWELL","type":"insert","ts":1234811111,"**xid**":2009527,"commit":true,"data":{"id":2,"name":"test"}}

Я хочу знать,

  1. Является ли этот xid уникальным для каждого события. Чтобы я мог использовать этот xid для уникальной идентификации события базы данных.
  2. Это даже возмущается по какой-то причине, у событий будет такой же xid?

Примечание. Я попытался повторно отправить одно и то же событие, вручную изменив position.binlog_positions и запустив новый экземпляр maxwell на новом сервере. Я получил те же xids для тех же событий из нового экземпляра maxwell.


apache-kafka bigdata maxwell
person WarWik    schedule 03.07.2016    source источник

Ответы (1)


arrow_upward
2
arrow_downward

xid происходит из binlog mysql и соответствует «transaction_id» innodb. Это уникально для транзакции, но только в контексте работающего сервера.

person Malinga    schedule 03.07.2016