2019/03/14 19:42

引用来自“ddatsh”的评论

所以增量数据要靠 poll.interval.ms 由kafka 定时触发而不是读 binlog实现的吧?

增量更新场景我还是还是喜欢 maxwell,
Kafka是一套完整的、有生态的解决方案,你说的maxwell只是一个符合特定场景的小软件,不是一个量级的。
在Confluent体系中,如果要从binlog读,可以采用Debezium Connector for MySQL。
2019/03/14 19:31

引用来自“dieslrae”的评论

基于主键和时间戳的增量怎么获取删除的数据
如果你要使用这种同步模式或者工具,就要针对他的功能和设计还有限制做专门的解决方案了。
就你的问题来说,可能业务上做物理删除就不行了,需要做逻辑删除,就是加个删除标志字段。
如果业务上一定要物理删除,那么可能就得考虑解析日志的源连接器了。
2019/03/13 14:51
基于主键和时间戳的增量怎么获取删除的数据
2019/03/13 12:23
所以增量数据要靠 poll.interval.ms 由kafka 定时触发而不是读 binlog实现的吧?

增量更新场景我还是还是喜欢 maxwell,
回复 @
{{emojiItem.symbol}}
返回顶部
顶部