• -------------------------------------------------------------
  • ====================================

标签:sinkTask

kafka之七 sinkTask

使用kafka connector 功能实现一个数据从kafka到 MySQL 的sinkTask一:实现 JdbcSinkConnector 类public class JdbcSinkConnector extends SinkConnector{ private String url; private String d……