基于canal和kafka