建立与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]

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