建立与Canal的连接代码bug

[EbonexDev]

if event_type == EntryProtocol_pb2.EventType.DELETE: for column in row.beforeColumns: format_data = { column.name: column.value } elif event_type == EntryProtocol_pb2.EventType.INSERT: for column in row.afterColumns: format_data = { column.name: column.value }

format_data = {column.name: column.value} 只会保留最后一个column的数据， 应该是format_data[column.name] = column.value

[linmp]

哈哈哈哈 我也发现这个问题了