json 被编码在一起这个问题,和 update 事件拆分逻辑无关。
从 v4.0.13 到 v7.5.3 的过程中,kafka sink 模块经历了重构,其中一项工作,是对于会将多条 events 编码到同一个 kafka message 的协议,会有一个提前赞批的操作,最多一次行赞批 2048 个 events 或者赞批操作耗时超过 15ms。maxwell 属于该种协议。
在编码的时候,maxwell encoder 一次性见到了多条 events,随后就给编码到了一起。
json 被编码在一起这个问题,和 update 事件拆分逻辑无关。
从 v4.0.13 到 v7.5.3 的过程中,kafka sink 模块经历了重构,其中一项工作,是对于会将多条 events 编码到同一个 kafka message 的协议,会有一个提前赞批的操作,最多一次行赞批 2048 个 events 或者赞批操作耗时超过 15ms。maxwell 属于该种协议。
在编码的时候,maxwell encoder 一次性见到了多条 events,随后就给编码到了一起。