package rdp.messages

Get desktop application:
View/edit binary Protocol Buffers messages

Column

Used in: Row

• required bytes name = 1

  column 名称

• required bytes type = 2

  column 类型：int32 varcher blob等，参见：enum_field_types

• required bytes value = 3

  column 内容

• optional uint32 binlog_type = 4

• optional string key = 5

  索引类型

• optional uint32 is_null = 6

Used in: Event

• kDDLNoChage = 0

  DDL没有变更

• kDDLChanged = 1

  DDL变更

Used in: Transaction

• optional bytes database_name = 1

• optional bytes table_name = 2

• required uint32 event_type = 3

• optional uint64 schema_id = 4

• required uint64 timestamp = 5

  数据库的binlog时间

• required uint64 timestamp_of_receipt = 6

  rdp处理binlog的时间

• optional DDL ddl = 7

  是否发生ddl变更

• optional uint64 position = 8

  在binlog文件中的位置

• optional uint64 next_position = 9

  下一条binlog的位置

• optional bytes binlog_file_name = 10

  binlog文件名

• optional uint64 server_id = 12

  ServerId Long mysql 实例的唯一性ID

• optional bytes sql_statement = 13

  sqlStatement String 表结构发生变化时的SQL

• repeated Row rows = 14

• optional bytes orig_buff = 15

  Event原始的二进制流

写入kafka数据

• required uint64 epoch = 1

  kafka 数据版本号

• required uint64 trans_seq_no = 2

  事务序号

• required bytes gtid = 3

  事务GTID

• required int32 split_flag = 4

  分包标识 0: 独立数据，没有分包操作 1: 分包数据，非最后分包 2: 分包数据，最后分包

• required uint64 seq_no = 5

  分包序号

• required bytes data = 6

  数据

• optional int64 checksum = 7

  Transaction数据校验值 在分包标识为0或者2的时候才存在

• optional uint32 flag = 8

  标识字段

• optional uint64 source_data_len = 9

  序列后后,压缩前Transaction的长度

• kKfkPkgDefault = 0

  没设置任何标识位

• kKfkPkgCompressData = 1

  KafkaPkg Data字段为压缩后数据

**************VMS Protobuf********************

Used in: VIPProperties, VMSMessage

• required string key = 1

• required string value = 2

Used in: Event

• repeated Column before = 14

  Insert、Delete情况下，只有before

• repeated Column after = 15

  Update情况下，before和after成对出现

mysql Transaction 数据

• required bytes gtid = 1

• required uint32 seq = 2

• repeated Event events = 3

• required uint64 position = 4

  在binlog文件中的位置

• required bytes binlog_file_name = 5

  binlog文件名

• required uint64 next_position = 6

  下一条binlog的位置

• required bytes next_binlog_file_name = 7

  binlog文件名

• optional int64 last_committed = 8

  group commit id

• optional int64 sequence_number = 9

  group commit sequence number

• required string version = 1

• repeated KeyPair properties = 2

• optional string messageId = 1

• optional uint64 weight = 2

• optional uint64 ttl = 3

• repeated string routingKeys = 4

• repeated KeyPair properties = 5

• required bytes payload = 6