历史切片：入职
数据分发
人工改库
员工数据版本
2021/11/30
事件分发
下游系统C
部门A
2021-10-29 14:33:45
2999-12-31
触发时间trigger_time
所在部门
小组长
295735
CoreHR
历史切片 seqNum = 1
工号170员工事件11-1去A部门et.add
LocalDate.now()
职位
295796
待生效切片：调职
mData
哪个库db_name
id
事件发生时间happen_time
哪个员工identifier_code
2021-06-02
推送失败
未来删除：双重沉默
哪条数据row_id
2022-11-30
正式员工
2021/01/01
未来改未来：沉默
2020-12-01 14:31:35
员工
王五
下游系统...
message-bus
删除导致的调职事件et.delete
maxwell + kafka
体系结构
未推送
abc
历史切片 seqNum = 2
员工性质
start_date
下游系统B
245691
2021-11-09
2022/11/29
概念1：事件发生时间（事件的版本号）
时间录错了，原有时间片上直接改调职时间确实改了，重新走了流程，原有时间片失效，重新写了一个
now
2021/06/02
部门B
2021-10-21 19:21:45
李四
历史切片：转正 seqNum = 3
update_time
工号170员工事件12-1去A部门et.delete
employee_id
主数据入库后比对数据版本发现手里的数据，此人的数据版本为11:57，数据旧，事件新，不支持推送
页面
主数据的数据缓存构建完毕开始比对未推送事件发现员工A的事件版本 = 数据版本执行推送
推送状态status
2021-06-01
事件结构试讲
2021/06/01
2021-11-08
事件生效时间effect_time
员工调职事件emp_transfer
excel导入
主数据开启新一轮的数据构建第一步是先获取数据版本此时拿到了员工A的数据最新版本12:00
2021/11/09
员工A的某事件推送事件状态改为\"已推送\"事件携带计算后的happen_time12:00
事件
晋升了
调职了
2022-11-29
2021/11/08
数据版本 ≥ 事件版本
事件类型event_type
张三
数据
新版本的数据
哪个表table_name
已推送
下游系统A
系统调用
直属上级
转正了
API
创建时间
时间线讲解
新增导致的调职事件et.add
end_date
试用正式员工
事件交互机制
kafka
2021-06-02 00:00:35
旧版本的数据
入职了，试用期
概念2：数据的版本号
双重沉默
工号170员工事件12-1去A部门et.update
2021-01-01
修改导致的调职事件et.modify
版本API
生效中切片：晋升
推送机制
沉默
2999/12/31
